Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

3.559s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.437s passed
testSpillListCompressed 1.259s passed
testSpillMap 0.516s passed
testSpillMapCompressed 0.347s passed

Standard output

2013-10-28 18:09:38,705 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:38,833 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:38,865 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:38,882 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:38,899 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:38,916 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:38,934 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:38,954 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:38,976 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:38,997 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:39,156 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:39,176 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:39,195 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:39,215 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:39,234 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:39,252 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:39,272 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:39,292 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:39,310 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:39,444 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:39,465 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:39,479 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:39,492 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:39,507 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:39,528 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:39,546 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:39,564 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:39,581 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:39,598 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1432
2013-10-28 18:09:39,729 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,732 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,739 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,740 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,742 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:39,747 INFO  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(40)) - Trying to load the custom-built native-hadoop library...
2013-10-28 18:09:39,749 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(47)) - Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path
2013-10-28 18:09:39,750 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(48)) - java.library.path=/usr/java/jdk1.6.0_31/jre/lib/amd64/server:/usr/java/jdk1.6.0_31/jre/lib/amd64:/usr/java/jdk1.6.0_31/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2013-10-28 18:09:39,752 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-28 18:09:39,754 WARN  zlib.ZlibFactory (ZlibFactory.java:<clinit>(64)) - Failed to load/initialize native-zlib library
2013-10-28 18:09:39,755 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,764 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:39,765 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,770 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:39,771 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,777 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:39,780 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,786 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-28 18:09:39,787 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,793 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-10-28 18:09:39,795 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,801 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:39,802 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,809 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:39,810 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,814 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-10-28 18:09:39,816 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,820 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-28 18:09:39,821 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,827 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,828 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,834 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,836 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,839 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,840 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,844 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,845 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,848 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,850 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,853 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,855 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,858 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,859 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,862 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,863 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,866 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,867 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,870 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:39,871 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:39,875 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:39,876 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 513
2013-10-28 18:09:40,241 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,243 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,245 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,246 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,248 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:40,250 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,253 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:40,263 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,274 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:40,282 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,292 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2013-10-28 18:09:40,297 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,305 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-28 18:09:40,311 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,317 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2013-10-28 18:09:40,328 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,331 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:40,335 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,343 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2013-10-28 18:09:40,347 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,352 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2013-10-28 18:09:40,358 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,367 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2013-10-28 18:09:40,383 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,399 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,400 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,402 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,409 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,419 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,423 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,427 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,431 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,434 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,441 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,448 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,451 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,455 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,458 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,462 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,465 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,468 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,474 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,477 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2013-10-28 18:09:40,480 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,483 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 18:09:40,486 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 342
2013-10-28 18:09:40,812 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:40,824 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,843 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:40,900 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:40,950 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:40,956 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,961 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:40,969 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,973 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:40,974 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,985 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:40,986 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:40,990 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:40,996 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,001 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:41,007 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,016 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:41,017 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,021 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:41,027 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,034 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:41,035 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,039 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,070 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,108 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,129 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,161 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,179 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,214 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,238 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,256 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,284 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,334 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:41,358 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,362 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:41,379 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,383 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:41,404 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,410 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:41,430 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,434 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:41,438 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,452 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:41,453 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,472 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:41,476 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,485 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:41,528 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,539 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:41,540 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,548 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,562 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,583 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,600 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,607 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,618 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,627 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,641 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,649 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,661 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,677 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2013-10-28 18:09:41,679 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,700 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2013-10-28 18:09:41,701 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,704 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2013-10-28 18:09:41,711 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,717 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2013-10-28 18:09:41,717 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,728 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2013-10-28 18:09:41,729 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,735 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2013-10-28 18:09:41,736 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,745 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2013-10-28 18:09:41,745 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,751 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2013-10-28 18:09:41,752 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,762 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2013-10-28 18:09:41,762 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,764 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2013-10-28 18:09:41,765 INFO  compress.CodecPool (CodecPool.java:getCompressor(106)) - Got brand-new compressor
2013-10-28 18:09:41,767 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,780 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,791 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,803 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,806 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,809 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,812 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,815 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,819 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,823 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
2013-10-28 18:09:41,826 INFO  compress.CodecPool (CodecPool.java:getDecompressor(141)) - Got brand-new decompressor
time = 1225