Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

2.609s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.512s passed
testSpillListCompressed 0.545s passed
testSpillMap 0.408s passed
testSpillMapCompressed 0.144s passed

Standard output

2014-08-22 15:00:32,128 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:32,266 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:32,288 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:32,309 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:32,331 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:32,353 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:32,375 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:32,397 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:32,419 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:32,441 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:32,611 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:32,632 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:32,652 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:32,673 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:32,693 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:32,712 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:32,734 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:32,754 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:32,773 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:32,919 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:32,938 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:32,957 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:32,976 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:32,995 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:33,013 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:33,032 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:33,050 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:33,067 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:33,084 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1510
2014-08-22 15:00:33,234 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,236 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,241 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,242 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,244 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,249 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 15:00:33,249 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,258 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,259 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,264 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,265 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,272 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,272 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,278 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 15:00:33,278 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,285 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 15:00:33,285 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,291 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,291 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,299 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,300 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,304 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 15:00:33,305 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,309 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 15:00:33,310 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,315 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,315 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,322 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,323 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,326 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,327 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,330 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,331 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,334 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,335 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,338 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,339 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,341 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,342 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,345 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,346 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,348 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,349 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,352 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,352 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,355 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,356 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 408
2014-08-22 15:00:33,633 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,634 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,635 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,636 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,637 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,638 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,641 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,642 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,644 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,645 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,647 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2014-08-22 15:00:33,648 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,650 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 15:00:33,651 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,653 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2014-08-22 15:00:33,654 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,656 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,657 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,660 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2014-08-22 15:00:33,660 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,663 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2014-08-22 15:00:33,663 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,666 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2014-08-22 15:00:33,667 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,669 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,670 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,671 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,672 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,674 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,675 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,677 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,678 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,679 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,680 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,682 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,683 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,684 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,685 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,687 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,688 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,689 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,690 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,692 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2014-08-22 15:00:33,693 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,694 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 15:00:33,695 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 143
2014-08-22 15:00:33,871 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:33,872 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,878 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:33,895 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:33,912 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:33,913 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,917 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:33,918 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,921 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:33,922 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,926 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:33,926 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,930 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:33,931 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,934 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:33,935 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,939 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:33,939 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,943 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:33,944 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,948 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:33,948 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:33,952 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:33,964 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:33,977 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:33,989 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,002 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,014 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,027 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,039 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,052 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,065 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,076 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:34,077 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,081 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:34,082 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,085 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:34,086 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,090 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:34,090 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,094 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:34,095 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,098 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:34,099 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,102 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:34,103 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,107 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:34,108 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,111 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:34,112 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,115 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,125 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,135 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,145 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,156 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,166 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,177 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,186 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,195 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,204 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,213 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2014-08-22 15:00:34,214 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,218 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2014-08-22 15:00:34,218 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,222 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2014-08-22 15:00:34,223 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,226 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2014-08-22 15:00:34,227 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,230 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2014-08-22 15:00:34,231 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,234 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2014-08-22 15:00:34,235 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,239 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2014-08-22 15:00:34,239 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,243 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2014-08-22 15:00:34,243 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,247 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2014-08-22 15:00:34,248 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,251 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2014-08-22 15:00:34,252 INFO  compress.CodecPool (CodecPool.java:getCompressor(103)) - Got brand-new compressor
2014-08-22 15:00:34,255 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,261 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,267 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,271 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,276 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,281 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,286 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,290 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,295 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,300 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
2014-08-22 15:00:34,305 INFO  compress.CodecPool (CodecPool.java:getDecompressor(128)) - Got brand-new decompressor
time = 528