Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

2.554s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.533s passed
testSpillListCompressed 0.503s passed
testSpillMap 0.387s passed
testSpillMapCompressed 0.131s passed

Standard output

2014-08-22 16:40:38,591 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:38,732 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:38,756 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:38,778 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:38,800 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:38,822 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:38,844 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:38,866 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:38,888 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:38,910 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:39,080 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:39,101 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:39,121 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:39,142 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:39,162 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:39,182 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:39,202 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:39,222 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:39,242 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:39,386 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:39,405 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:39,423 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:39,442 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:39,460 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:39,478 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:39,496 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:39,514 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:39,531 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:39,548 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1531
2014-08-22 16:40:39,694 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,695 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,701 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,701 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,703 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:39,708 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 16:40:39,709 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,718 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:39,719 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,724 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:39,725 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,731 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:39,732 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,737 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 16:40:39,738 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,744 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 16:40:39,745 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,750 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:39,751 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,758 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:39,759 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,763 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 16:40:39,764 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,768 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 16:40:39,769 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,773 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,774 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,780 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,781 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,784 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,785 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,788 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,788 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,791 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,792 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,794 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,795 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,797 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,798 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,800 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,801 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,803 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,804 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,806 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:39,807 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:39,809 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:39,810 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 387
2014-08-22 16:40:40,073 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,074 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,074 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,075 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,076 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:40,076 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,082 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:40,083 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,085 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:40,086 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,088 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 16:40:40,089 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,091 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 16:40:40,091 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,093 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 16:40:40,094 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,096 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:40,097 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,099 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 16:40:40,099 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,101 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 16:40:40,102 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,104 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 16:40:40,105 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,107 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,107 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,109 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,109 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,111 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,112 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,113 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,114 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,115 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,116 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,117 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,118 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,119 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,120 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,121 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,122 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,123 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,124 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,125 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 16:40:40,126 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,128 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 16:40:40,128 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 130
2014-08-22 16:40:40,272 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:40,272 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,278 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,296 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,312 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:40,313 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,317 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:40,317 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,321 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:40,321 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,325 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:40,325 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,329 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:40,329 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,332 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:40,333 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,336 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:40,337 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,340 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:40,341 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,345 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:40,345 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,349 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,362 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,376 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,389 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,403 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,418 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,432 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,446 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,460 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,471 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,481 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:40,482 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,486 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:40,487 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,490 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:40,490 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,494 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:40,494 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,497 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:40,498 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,501 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:40,502 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,505 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:40,506 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,509 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:40,510 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,513 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:40,513 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,517 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,524 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,532 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,539 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,549 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,558 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,565 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,571 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,577 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,584 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,593 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 16:40:40,594 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,598 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 16:40:40,598 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,601 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 16:40:40,602 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,605 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 16:40:40,605 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,609 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 16:40:40,609 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,612 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 16:40:40,613 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,616 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 16:40:40,616 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,632 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 16:40:40,632 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,635 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 16:40:40,636 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,639 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2014-08-22 16:40:40,639 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 16:40:40,642 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,648 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,653 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,658 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,662 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,666 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,671 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,675 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,680 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,684 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 16:40:40,689 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
time = 486