Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

2.660s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.585s passed
testSpillListCompressed 0.556s passed
testSpillMap 0.384s passed
testSpillMapCompressed 0.135s passed

Standard output

2014-08-22 17:45:04,023 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:04,152 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:04,174 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:04,196 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:04,219 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:04,241 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:04,264 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:04,286 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:04,309 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:04,331 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:04,504 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:04,526 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:04,547 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:04,568 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:04,589 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:04,609 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:04,632 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:04,652 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:04,672 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:04,837 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:04,856 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:04,874 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:04,892 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:04,911 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:04,929 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:04,947 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:04,965 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:04,983 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:05,000 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1583
2014-08-22 17:45:05,149 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,151 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,156 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,156 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,158 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,162 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-08-22 17:45:05,162 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,171 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,171 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,176 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,177 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,183 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,184 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,189 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 17:45:05,189 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,195 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 17:45:05,196 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,201 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,201 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,209 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,209 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,213 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 17:45:05,214 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,218 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 17:45:05,218 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,223 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,223 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,229 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,229 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,232 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,233 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,236 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,236 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,239 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,239 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,242 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,243 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,245 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,245 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,248 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,248 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,251 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,251 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,253 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,254 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,256 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,257 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 383
2014-08-22 17:45:05,527 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,527 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,529 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,529 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,531 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,532 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,535 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,536 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,538 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,539 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,541 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 17:45:05,542 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,544 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 17:45:05,545 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,547 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 17:45:05,548 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,550 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,551 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,554 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 17:45:05,554 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,557 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 17:45:05,557 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,560 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 17:45:05,561 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,563 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,564 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,565 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,566 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,568 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,569 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,571 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,572 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,573 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,574 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,576 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,577 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,578 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,579 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,581 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,582 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,583 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,584 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,586 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 17:45:05,586 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,588 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:45:05,589 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 134
2014-08-22 17:45:05,763 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:05,764 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,771 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,789 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,808 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:05,809 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,814 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:05,814 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,818 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:05,819 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,822 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:05,823 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,827 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:05,828 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,831 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:05,832 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,836 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:05,837 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,840 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:05,841 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,845 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:05,846 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,849 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,863 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,878 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,891 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,906 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,919 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,934 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,948 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,962 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,976 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:05,986 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:05,987 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,991 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:05,992 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:05,996 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:05,997 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,000 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:06,001 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,004 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:06,005 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,009 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:06,009 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,013 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:06,014 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,017 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:06,018 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,022 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:06,022 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,026 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,034 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,041 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,049 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,059 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,068 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,076 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,082 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,090 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,098 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,108 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 17:45:06,109 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,113 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 17:45:06,113 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,117 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 17:45:06,118 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,121 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 17:45:06,122 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,125 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 17:45:06,126 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,129 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 17:45:06,130 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,133 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 17:45:06,134 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,138 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 17:45:06,138 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,142 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 17:45:06,142 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,146 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2014-08-22 17:45:06,147 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 17:45:06,150 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,155 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,160 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,165 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,169 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,174 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,179 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,183 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,188 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,193 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 17:45:06,198 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
time = 537