Class cascading.tuple.hadoop.SpillableTupleHadoopTest

4

tests

0

failures

0

ignored

1.833s

duration

100%

successful

Tests

Test Duration Result
testSpillList 1.162s passed
testSpillListCompressed 0.304s passed
testSpillMap 0.271s passed
testSpillMapCompressed 0.096s passed

Standard output

2015-02-12 12:31:21,473 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:21,581 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:21,592 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:21,600 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:21,606 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:21,614 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:21,623 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:21,632 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:21,641 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:21,649 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:21,748 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:21,757 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:21,766 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:21,774 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:21,783 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:21,796 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:21,812 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:21,824 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:21,841 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:22,004 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:22,011 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:22,018 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:22,026 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:22,033 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:22,040 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:22,048 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:22,057 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:22,064 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:22,070 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
time = 1161
2015-02-12 12:31:22,135 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,136 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,139 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,139 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,140 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,164 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-12 12:31:22,164 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,170 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,170 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,174 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,176 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,182 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,182 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,185 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2015-02-12 12:31:22,185 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,188 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2015-02-12 12:31:22,189 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,192 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,193 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,196 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,196 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,199 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2015-02-12 12:31:22,199 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,202 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2015-02-12 12:31:22,203 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,206 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,207 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,210 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,211 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,213 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,213 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,215 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,215 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,217 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,218 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,220 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,221 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,223 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,224 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,226 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,227 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,230 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,231 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,232 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,233 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,234 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,234 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 269
2015-02-12 12:31:22,402 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,402 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,403 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,404 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,404 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,405 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,407 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,407 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,408 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,409 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,410 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 1
2015-02-12 12:31:22,410 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,411 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2015-02-12 12:31:22,412 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,413 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 4
2015-02-12 12:31:22,413 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,415 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,415 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,416 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 2
2015-02-12 12:31:22,417 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,418 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 5
2015-02-12 12:31:22,419 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,420 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 20 tuples in list to spill number 3
2015-02-12 12:31:22,420 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,422 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,422 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,425 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,427 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,428 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,429 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,430 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,431 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,433 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,433 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,434 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,435 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,435 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,436 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,437 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,438 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,439 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,439 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,440 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 10 tuples in list to spill number 1
2015-02-12 12:31:22,441 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,442 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-02-12 12:31:22,443 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
time = 96
2015-02-12 12:31:22,550 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:22,551 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,555 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,567 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,576 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:22,577 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,579 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:22,580 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,582 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:22,582 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,584 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:22,585 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,588 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:22,589 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,591 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:22,591 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,594 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:22,595 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,597 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:22,597 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,599 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:22,600 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,602 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,607 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,613 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,618 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,623 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,627 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,634 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,642 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,649 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,653 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,664 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:22,665 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,668 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:22,668 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,670 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:22,671 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,673 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:22,673 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,677 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:22,677 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,680 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:22,682 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,684 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:22,684 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,686 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:22,686 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,689 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:22,689 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,692 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,696 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,701 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,704 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,707 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,710 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,713 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,715 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,719 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,723 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,731 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 1
2015-02-12 12:31:22,732 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,734 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 2
2015-02-12 12:31:22,734 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,736 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 3
2015-02-12 12:31:22,736 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,738 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 4
2015-02-12 12:31:22,739 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,741 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 5
2015-02-12 12:31:22,743 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,745 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 6
2015-02-12 12:31:22,746 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,748 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 7
2015-02-12 12:31:22,748 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,750 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 8
2015-02-12 12:31:22,751 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,753 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 9
2015-02-12 12:31:22,754 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,756 INFO  collect.Spillable$SpillListener (Spillable.java:notifyWriteSpillBegin(48)) - spilling 50 tuples in list to spill number 10
2015-02-12 12:31:22,756 INFO  compress.CodecPool (CodecPool.java:getCompressor(151)) - Got brand-new compressor [.gz]
2015-02-12 12:31:22,758 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,761 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,766 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,770 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,774 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,777 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,780 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,782 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,785 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,787 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
2015-02-12 12:31:22,789 INFO  compress.CodecPool (CodecPool.java:getDecompressor(179)) - Got brand-new decompressor [.gz]
time = 284