Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

1.374s

duration

100%

successful

Tests

Test Duration Result
testSpillList 0.702s passed
testSpillListCompressed 0.325s passed
testSpillMap 0.272s passed
testSpillMapCompressed 0.075s passed

Standard output

2013-10-31 20:27:02,556 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:02,620 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:02,628 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:02,636 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:02,643 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:02,650 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:02,658 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:02,665 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:02,672 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:02,679 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:02,756 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:02,762 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:02,769 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:02,776 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:02,782 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:02,789 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:02,796 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:02,803 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:02,809 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:02,874 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:02,880 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:02,886 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:02,891 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:02,897 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:02,902 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:02,908 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:02,914 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:02,919 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:02,925 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 701
2013-10-31 20:27:02,990 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:02,990 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:02,994 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:02,994 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:02,996 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:02,998 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-31 20:27:02,999 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,004 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:03,004 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,007 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,008 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,011 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:03,012 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,015 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-31 20:27:03,015 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,019 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-10-31 20:27:03,019 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,022 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,022 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,027 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,027 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,031 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-10-31 20:27:03,032 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,033 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-31 20:27:03,034 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,036 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,036 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,040 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,041 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,042 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,042 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,044 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,044 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,045 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,045 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,047 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,047 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,048 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,048 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,049 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,049 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,051 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,051 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,052 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,052 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,053 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,053 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 271
2013-10-31 20:27:03,254 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,255 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,255 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,255 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,256 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:03,256 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,258 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:03,258 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,259 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,259 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,261 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-31 20:27:03,261 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,262 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-31 20:27:03,262 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,263 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-10-31 20:27:03,263 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,264 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,265 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,266 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-31 20:27:03,266 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,267 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-10-31 20:27:03,267 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,268 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-31 20:27:03,269 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,270 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,270 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,271 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,271 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,272 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,272 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,273 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,273 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,274 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,274 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,275 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,275 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,276 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,276 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,277 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,277 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,277 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,278 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,278 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-31 20:27:03,278 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,279 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-31 20:27:03,279 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 75
2013-10-31 20:27:03,379 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:03,380 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,383 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,395 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,410 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:03,411 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,413 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:03,413 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,415 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:03,415 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,417 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:03,417 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,419 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:03,420 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,421 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:03,422 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,424 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:03,424 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,426 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:03,426 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,428 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:03,428 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,430 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,439 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,448 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,456 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,465 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,474 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,483 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,492 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,501 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,509 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,516 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:03,516 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,519 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:03,519 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,521 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:03,521 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,523 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:03,523 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,525 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:03,526 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,528 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:03,528 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,530 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:03,530 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,532 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:03,533 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,535 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:03,535 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,537 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,542 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,546 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,551 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,555 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,559 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,563 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,568 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,572 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,576 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,584 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-31 20:27:03,584 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,586 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-31 20:27:03,586 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,588 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-31 20:27:03,588 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,590 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-31 20:27:03,590 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,592 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-31 20:27:03,593 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,594 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-31 20:27:03,595 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,597 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-31 20:27:03,597 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,599 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-31 20:27:03,599 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,601 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-31 20:27:03,601 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,603 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2013-10-31 20:27:03,603 INFO  compress.CodecPool (CodecPool.java:getCompressor(104)) - Got brand-new compressor
2013-10-31 20:27:03,605 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,609 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,613 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,616 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,620 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,624 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,627 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,631 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,635 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,639 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
2013-10-31 20:27:03,642 INFO  compress.CodecPool (CodecPool.java:getDecompressor(132)) - Got brand-new decompressor
time = 313