Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

2.220s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.299s passed
testSpillListCompressed 0.464s passed
testSpillMap 0.334s passed
testSpillMapCompressed 0.123s passed

Standard output

2013-11-20 14:19:03,260 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:03,365 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:03,384 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:03,402 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:03,419 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:03,437 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:03,455 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:03,473 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:03,491 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:03,509 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:03,654 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:03,672 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:03,689 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:03,706 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:03,723 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:03,739 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:03,757 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:03,773 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:03,789 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:03,913 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:03,929 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:03,944 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:03,959 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:03,974 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:03,990 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:04,005 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:04,020 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:04,034 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:04,048 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1298
2013-11-20 14:19:04,173 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,174 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,179 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,179 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,181 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,184 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 14:19:04,185 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,192 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,193 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,197 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,197 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,203 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,203 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,207 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-11-20 14:19:04,207 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,212 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-11-20 14:19:04,213 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,217 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,218 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,224 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,224 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,230 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-11-20 14:19:04,230 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,233 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-11-20 14:19:04,234 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,237 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,238 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,242 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,243 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,245 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,246 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,248 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,249 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,250 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,251 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,253 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,253 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,255 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,255 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,257 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,258 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,260 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,260 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,262 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,262 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,265 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,265 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 333
2013-11-20 14:19:04,500 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,500 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,501 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,501 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,502 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,502 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,505 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,505 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,507 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,507 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,509 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-11-20 14:19:04,509 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,511 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-11-20 14:19:04,511 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,513 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-11-20 14:19:04,514 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,515 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,516 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,518 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-11-20 14:19:04,518 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,520 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-11-20 14:19:04,520 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,522 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-11-20 14:19:04,522 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,525 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,525 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,526 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,526 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,529 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,529 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,530 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,531 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,532 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,533 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,534 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,535 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,536 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,536 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,538 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,538 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,539 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,540 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,541 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-11-20 14:19:04,542 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,543 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-11-20 14:19:04,544 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 122
2013-11-20 14:19:04,704 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:04,704 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,709 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,724 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,739 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:04,740 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,743 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:04,744 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,746 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:04,747 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,750 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:04,750 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,753 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:04,754 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,757 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:04,757 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,760 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:04,760 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,763 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:04,764 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,767 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:04,767 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,770 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,781 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,793 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,804 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,816 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,827 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,839 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,850 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,862 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,874 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,883 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:04,884 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,887 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:04,888 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,890 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:04,891 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,893 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:04,894 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,897 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:04,897 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,900 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:04,901 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,904 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:04,905 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,908 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:04,908 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,911 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:04,911 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:04,914 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,922 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,930 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,938 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,946 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,955 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,963 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,971 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,979 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,987 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:04,996 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-11-20 14:19:04,997 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,000 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-11-20 14:19:05,001 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,003 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-11-20 14:19:05,004 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,007 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-11-20 14:19:05,007 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,010 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-11-20 14:19:05,010 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,013 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-11-20 14:19:05,013 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,017 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-11-20 14:19:05,017 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,020 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-11-20 14:19:05,020 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,023 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-11-20 14:19:05,023 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,026 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2013-11-20 14:19:05,026 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2013-11-20 14:19:05,029 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,034 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,039 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,043 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,047 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,050 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,054 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,058 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,062 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,065 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2013-11-20 14:19:05,069 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
time = 449