2013-10-23 22:40:06,998 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-23 22:40:07,012 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-23 22:40:07,012 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2013-10-23 22:40:07,028 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-23 22:40:07,290 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:07,292 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:07,300 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 0BDDCF36F9D24114895FA8949D149C6E
2013-10-23 22:40:07,426 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-23 22:40:07,428 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:07,428 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:07,428 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-10-23 22:40:07,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:07,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 2
2013-10-23 22:40:07,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:07,430 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/2)
2013-10-23 22:40:07,457 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-23 22:40:07,499 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-10-23 22:40:07,502 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:07,647 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1100756710_0001
2013-10-23 22:40:07,664 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:07,666 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1100756710_0001_m_000000_0
2013-10-23 22:40:07,690 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:07,694 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:07,695 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4f299f7e
2013-10-23 22:40:07,700 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:07,704 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:07,800 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:07,800 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:07,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:07,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:07,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:07,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:07,864 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:07,874 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:07,876 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1100756710_0001_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:07,880 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:07,880 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1100756710_0001_m_000000_0' done.
2013-10-23 22:40:07,880 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1100756710_0001_m_000000_0
2013-10-23 22:40:07,880 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:07,888 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:07,888 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:07,893 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:07,897 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-23 22:40:07,898 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:07,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:07,899 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:07,911 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:07,911 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][9547394763/test/]
2013-10-23 22:40:07,926 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1100756710_0001_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:07,927 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:07,927 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1100756710_0001_r_000000_0 is allowed to commit now
2013-10-23 22:40:07,930 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1100756710_0001_r_000000_0' to file:/tmp/hadoop-jwfbean/9547394763_test_682A575596F84D52B8352FAEE0617E57
2013-10-23 22:40:07,931 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:07,931 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1100756710_0001_r_000000_0' done.
2013-10-23 22:40:07,943 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2013-10-23 22:40:07,954 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,012 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local56549500_0002
2013-10-23 22:40:08,014 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,014 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local56549500_0002_m_000000_0
2013-10-23 22:40:08,016 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,017 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-jwfbean/9547394763_test_682A575596F84D52B8352FAEE0617E57/part-00000
2013-10-23 22:40:08,018 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@45c81ac0
2013-10-23 22:40:08,022 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:08,022 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:08,084 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:08,084 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:08,086 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:08,086 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][9547394763/test/]
2013-10-23 22:40:08,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:08,097 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:08,099 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:08,101 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local56549500_0002_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,104 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/tmp/hadoop-jwfbean/9547394763_test_682A575596F84D52B8352FAEE0617E57/part-00000:0+310
2013-10-23 22:40:08,104 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local56549500_0002_m_000000_0' done.
2013-10-23 22:40:08,104 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local56549500_0002_m_000000_0
2013-10-23 22:40:08,105 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:08,111 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,112 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,113 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:08,113 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 202 bytes
2013-10-23 22:40:08,114 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,114 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:08,114 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,124 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:08,124 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplechain"]
2013-10-23 22:40:08,130 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local56549500_0002_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,132 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,132 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local56549500_0002_r_000000_0 is allowed to commit now
2013-10-23 22:40:08,135 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local56549500_0002_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplechain
2013-10-23 22:40:08,136 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:08,136 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local56549500_0002_r_000000_0' done.
2013-10-23 22:40:08,151 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplechain/_temporary
2013-10-23 22:40:08,168 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/simplechain
2013-10-23 22:40:08,183 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:08,183 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:08,197 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-23 22:40:08,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:08,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count"]
2013-10-23 22:40:08,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] parallel execution is enabled: false
2013-10-23 22:40:08,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting jobs: 1
2013-10-23 22:40:08,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] allocating threads: 1
2013-10-23 22:40:08,198 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) .../basicpipesplatform/count
2013-10-23 22:40:08,209 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local1040236475_0003
2013-10-23 22:40:08,253 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,253 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1040236475_0003_m_000000_0
2013-10-23 22:40:08,255 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,256 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt
2013-10-23 22:40:08,256 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@49d29a78
2013-10-23 22:40:08,258 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:08,258 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:08,319 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:08,320 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:08,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:08,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,331 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:08,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:08,336 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:08,341 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:08,343 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1040236475_0003_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,345 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt:0+275
2013-10-23 22:40:08,345 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1040236475_0003_m_000000_0' done.
2013-10-23 22:40:08,345 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1040236475_0003_m_000000_0
2013-10-23 22:40:08,346 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:08,349 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,350 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,351 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:08,351 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-23 22:40:08,352 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,352 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:08,352 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:08,361 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count"]
2013-10-23 22:40:08,370 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1040236475_0003_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,371 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,371 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1040236475_0003_r_000000_0 is allowed to commit now
2013-10-23 22:40:08,374 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1040236475_0003_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count
2013-10-23 22:40:08,375 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:08,375 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1040236475_0003_r_000000_0' done.
2013-10-23 22:40:08,384 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count/_temporary
2013-10-23 22:40:08,395 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,405 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,406 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/count
2013-10-23 22:40:08,415 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:08,416 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:08,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:08,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:08,429 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/swap"]
2013-10-23 22:40:08,430 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:08,430 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:08,430 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:08,430 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...p/basicpipesplatform/swap
2013-10-23 22:40:08,444 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,473 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1421546178_0004
2013-10-23 22:40:08,475 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,475 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1421546178_0004_m_000000_0
2013-10-23 22:40:08,476 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,477 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:08,477 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@10bcc8f4
2013-10-23 22:40:08,478 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 22:40:08,481 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:08,481 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:08,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/swap"]
2013-10-23 22:40:08,488 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1421546178_0004_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,489 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,490 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1421546178_0004_m_000000_0 is allowed to commit now
2013-10-23 22:40:08,492 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1421546178_0004_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/swap
2013-10-23 22:40:08,492 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:08,493 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1421546178_0004_m_000000_0' done.
2013-10-23 22:40:08,493 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1421546178_0004_m_000000_0
2013-10-23 22:40:08,493 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:08,507 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/swap/_temporary
2013-10-23 22:40:08,516 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,517 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/swap
2013-10-23 22:40:08,529 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:08,529 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:08,542 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:08,542 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower+upper.txt"]
2013-10-23 22:40:08,543 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-10-23 22:40:08,543 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:08,543 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:08,543 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:08,543 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2013-10-23 22:40:08,553 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,578 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1198691468_0005
2013-10-23 22:40:08,580 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,580 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1198691468_0005_m_000000_0
2013-10-23 22:40:08,581 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,582 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower+upper.txt
2013-10-23 22:40:08,583 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@19b72276
2013-10-23 22:40:08,584 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 22:40:08,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:08,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower+upper.txt"]
2013-10-23 22:40:08,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/ungrouped"]
2013-10-23 22:40:08,597 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1198691468_0005_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,598 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,598 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1198691468_0005_m_000000_0 is allowed to commit now
2013-10-23 22:40:08,600 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1198691468_0005_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/ungrouped
2013-10-23 22:40:08,601 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower+upper.txt:0+30
2013-10-23 22:40:08,601 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1198691468_0005_m_000000_0' done.
2013-10-23 22:40:08,601 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1198691468_0005_m_000000_0
2013-10-23 22:40:08,601 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:08,612 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/ungrouped/_temporary
2013-10-23 22:40:08,621 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,622 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/ungrouped
2013-10-23 22:40:08,631 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:08,632 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:08,647 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:08,648 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...esplatform/simplerelative
2013-10-23 22:40:08,657 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,682 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local153638376_0006
2013-10-23 22:40:08,684 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,684 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local153638376_0006_m_000000_0
2013-10-23 22:40:08,685 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,686 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:08,686 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@72bdec44
2013-10-23 22:40:08,687 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:08,687 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:08,747 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:08,747 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:08,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:08,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,756 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:08,756 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:08,757 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:08,760 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:08,761 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local153638376_0006_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,763 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:08,763 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local153638376_0006_m_000000_0' done.
2013-10-23 22:40:08,763 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local153638376_0006_m_000000_0
2013-10-23 22:40:08,764 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:08,766 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,767 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,767 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:08,767 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-23 22:40:08,768 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:08,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:08,775 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:08,775 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplerelative"]
2013-10-23 22:40:08,782 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local153638376_0006_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:08,784 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:08,784 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local153638376_0006_r_000000_0 is allowed to commit now
2013-10-23 22:40:08,786 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local153638376_0006_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplerelative
2013-10-23 22:40:08,787 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:08,787 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local153638376_0006_r_000000_0' done.
2013-10-23 22:40:08,800 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simplerelative/_temporary
2013-10-23 22:40:08,808 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,809 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/simplerelative
2013-10-23 22:40:08,915 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:08,916 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:08,934 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:08,934 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt"]
2013-10-23 22:40:08,935 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-10-23 22:40:08,935 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:08,935 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:08,935 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:08,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2013-10-23 22:40:08,944 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:08,968 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local934291334_0007
2013-10-23 22:40:08,970 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:08,970 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local934291334_0007_m_000000_0
2013-10-23 22:40:08,971 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:08,972 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt
2013-10-23 22:40:08,973 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@55641ee0
2013-10-23 22:40:08,974 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:08,974 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:09,038 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:09,038 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:09,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,047 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt"]
2013-10-23 22:40:09,047 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:09,109 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:09,110 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:09,112 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local934291334_0007_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,114 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt:0+19
2013-10-23 22:40:09,114 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local934291334_0007_m_000000_0' done.
2013-10-23 22:40:09,114 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local934291334_0007_m_000000_0
2013-10-23 22:40:09,114 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,116 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,117 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,117 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:09,117 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 28 bytes
2013-10-23 22:40:09,118 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:09,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,128 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:09,128 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simpleresult"]
2013-10-23 22:40:09,132 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local934291334_0007_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,133 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,133 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local934291334_0007_r_000000_0 is allowed to commit now
2013-10-23 22:40:09,135 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local934291334_0007_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simpleresult
2013-10-23 22:40:09,135 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:09,136 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local934291334_0007_r_000000_0' done.
2013-10-23 22:40:09,147 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simpleresult/_temporary
2013-10-23 22:40:09,154 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,156 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/simpleresult
2013-10-23 22:40:09,162 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,163 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,172 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:09,173 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:09,173 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-10-23 22:40:09,173 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:09,173 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:09,173 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:09,173 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2013-10-23 22:40:09,183 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,203 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local2098447744_0008
2013-10-23 22:40:09,205 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:09,205 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2098447744_0008_m_000000_0
2013-10-23 22:40:09,206 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,207 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:09,208 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@18b9459c
2013-10-23 22:40:09,209 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 22:40:09,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:09,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filterall"]
2013-10-23 22:40:09,221 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local2098447744_0008_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,223 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,223 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local2098447744_0008_m_000000_0 is allowed to commit now
2013-10-23 22:40:09,226 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2098447744_0008_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filterall
2013-10-23 22:40:09,227 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:09,227 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2098447744_0008_m_000000_0' done.
2013-10-23 22:40:09,227 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2098447744_0008_m_000000_0
2013-10-23 22:40:09,227 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,238 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filterall/_temporary
2013-10-23 22:40:09,253 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,254 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/filterall
2013-10-23 22:40:09,262 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,262 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,282 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting
2013-10-23 22:40:09,282 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/upper.txt"]
2013-10-23 22:40:09,282 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt"]
2013-10-23 22:40:09,283 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-10-23 22:40:09,283 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] parallel execution is enabled: false
2013-10-23 22:40:09,283 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting jobs: 1
2013-10-23 22:40:09,283 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] allocating threads: 1
2013-10-23 22:40:09,283 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2013-10-23 22:40:09,290 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,291 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,309 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] submitted hadoop job: job_local803322218_0009
2013-10-23 22:40:09,310 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:09,311 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local803322218_0009_m_000000_0
2013-10-23 22:40:09,312 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,313 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt
2013-10-23 22:40:09,313 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@111f2041
2013-10-23 22:40:09,314 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:09,314 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:09,375 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:09,376 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:09,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt"]
2013-10-23 22:40:09,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-23 22:40:09,385 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:09,387 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:09,388 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local803322218_0009_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,390 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/lower.txt:0+19
2013-10-23 22:40:09,390 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local803322218_0009_m_000000_0' done.
2013-10-23 22:40:09,390 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local803322218_0009_m_000000_0
2013-10-23 22:40:09,390 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local803322218_0009_m_000001_0
2013-10-23 22:40:09,391 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,391 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/upper.txt
2013-10-23 22:40:09,392 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@baf1915
2013-10-23 22:40:09,392 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:09,393 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:09,454 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:09,454 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:09,455 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,455 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,463 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/upper.txt"]
2013-10-23 22:40:09,463 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-23 22:40:09,464 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:09,466 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:09,468 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local803322218_0009_m_000001_0 is done. And is in the process of commiting
2013-10-23 22:40:09,469 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/upper.txt:0+19
2013-10-23 22:40:09,469 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local803322218_0009_m_000001_0' done.
2013-10-23 22:40:09,469 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local803322218_0009_m_000001_0
2013-10-23 22:40:09,470 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,474 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,475 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,475 INFO mapred.Merger (Merger.java:merge(408)) - Merging 2 sorted segments
2013-10-23 22:40:09,476 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2013-10-23 22:40:09,476 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,477 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:09,477 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,482 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2013-10-23 22:40:09,482 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/complexcogroup"]
2013-10-23 22:40:09,489 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-23 22:40:09,489 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-23 22:40:09,494 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local803322218_0009_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,495 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,496 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local803322218_0009_r_000000_0 is allowed to commit now
2013-10-23 22:40:09,498 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local803322218_0009_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/complexcogroup
2013-10-23 22:40:09,498 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:09,499 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local803322218_0009_r_000000_0' done.
2013-10-23 22:40:09,510 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/complexcogroup/_temporary
2013-10-23 22:40:09,517 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,524 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,525 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/complexcogroup
2013-10-23 22:40:09,530 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,531 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,539 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:09,540 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:09,540 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/replace"]
2013-10-23 22:40:09,540 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:09,540 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:09,540 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:09,540 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2013-10-23 22:40:09,547 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,564 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local391781338_0010
2013-10-23 22:40:09,565 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:09,565 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local391781338_0010_m_000000_0
2013-10-23 22:40:09,566 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,567 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:09,567 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7ad3f189
2013-10-23 22:40:09,568 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 22:40:09,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,574 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:09,575 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/replace"]
2013-10-23 22:40:09,577 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local391781338_0010_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,578 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,578 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local391781338_0010_m_000000_0 is allowed to commit now
2013-10-23 22:40:09,580 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local391781338_0010_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/replace
2013-10-23 22:40:09,581 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:09,581 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local391781338_0010_m_000000_0' done.
2013-10-23 22:40:09,581 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local391781338_0010_m_000000_0
2013-10-23 22:40:09,581 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,586 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/replace/_temporary
2013-10-23 22:40:09,593 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,595 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/replace
2013-10-23 22:40:09,603 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,604 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,614 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-23 22:40:09,614 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:09,614 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count2"]
2013-10-23 22:40:09,614 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] parallel execution is enabled: false
2013-10-23 22:40:09,615 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting jobs: 1
2013-10-23 22:40:09,615 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] allocating threads: 1
2013-10-23 22:40:09,615 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2013-10-23 22:40:09,623 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local1269698610_0011
2013-10-23 22:40:09,646 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:09,646 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1269698610_0011_m_000000_0
2013-10-23 22:40:09,648 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,648 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt
2013-10-23 22:40:09,649 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3f0dbef1
2013-10-23 22:40:09,649 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:09,650 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:09,716 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:09,716 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:09,717 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,718 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,722 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:09,722 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:09,725 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:09,728 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:09,730 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1269698610_0011_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,732 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt:0+275
2013-10-23 22:40:09,732 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1269698610_0011_m_000000_0' done.
2013-10-23 22:40:09,732 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1269698610_0011_m_000000_0
2013-10-23 22:40:09,732 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,735 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,735 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,736 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:09,736 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-23 22:40:09,737 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,737 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:09,737 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,741 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:09,741 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count2"]
2013-10-23 22:40:09,747 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1269698610_0011_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,748 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,749 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1269698610_0011_r_000000_0 is allowed to commit now
2013-10-23 22:40:09,751 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1269698610_0011_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count2
2013-10-23 22:40:09,752 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:09,752 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1269698610_0011_r_000000_0' done.
2013-10-23 22:40:09,760 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count2/_temporary
2013-10-23 22:40:09,767 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,776 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,777 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/count2
2013-10-23 22:40:09,784 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,784 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,795 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-23 22:40:09,796 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:09,796 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count3"]
2013-10-23 22:40:09,796 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] parallel execution is enabled: false
2013-10-23 22:40:09,796 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting jobs: 1
2013-10-23 22:40:09,796 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] allocating threads: 1
2013-10-23 22:40:09,796 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2013-10-23 22:40:09,805 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local415037027_0012
2013-10-23 22:40:09,825 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:09,825 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local415037027_0012_m_000000_0
2013-10-23 22:40:09,827 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,828 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt
2013-10-23 22:40:09,828 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@68c884e
2013-10-23 22:40:09,829 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:09,830 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:09,894 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:09,894 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:09,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:09,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:09,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:09,904 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:09,908 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:09,909 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local415037027_0012_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,911 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt:0+275
2013-10-23 22:40:09,912 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local415037027_0012_m_000000_0' done.
2013-10-23 22:40:09,912 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local415037027_0012_m_000000_0
2013-10-23 22:40:09,912 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:09,915 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:09,915 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,916 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:09,916 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-23 22:40:09,917 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,917 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:09,918 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:09,923 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:09,924 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count3"]
2013-10-23 22:40:09,930 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local415037027_0012_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:09,932 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:09,932 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local415037027_0012_r_000000_0 is allowed to commit now
2013-10-23 22:40:09,934 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local415037027_0012_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count3
2013-10-23 22:40:09,935 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:09,935 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local415037027_0012_r_000000_0' done.
2013-10-23 22:40:09,949 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count3/_temporary
2013-10-23 22:40:09,956 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,963 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:09,965 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/count3
2013-10-23 22:40:09,972 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:09,972 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:09,982 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting
2013-10-23 22:40:09,983 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:09,983 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count4"]
2013-10-23 22:40:09,983 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] parallel execution is enabled: false
2013-10-23 22:40:09,983 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] starting jobs: 1
2013-10-23 22:40:09,983 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [count] allocating threads: 1
2013-10-23 22:40:09,983 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2013-10-23 22:40:09,991 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,012 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [count] submitted hadoop job: job_local850237118_0013
2013-10-23 22:40:10,013 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:10,014 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local850237118_0013_m_000000_0
2013-10-23 22:40:10,015 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:10,016 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt
2013-10-23 22:40:10,017 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@32d2bb53
2013-10-23 22:40:10,017 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:10,018 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:10,079 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:10,079 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:10,080 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:10,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:10,087 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt"]
2013-10-23 22:40:10,087 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:10,089 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:10,092 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:10,093 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local850237118_0013_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:10,094 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/ips.20.txt:0+275
2013-10-23 22:40:10,094 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local850237118_0013_m_000000_0' done.
2013-10-23 22:40:10,094 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local850237118_0013_m_000000_0
2013-10-23 22:40:10,094 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:10,097 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:10,097 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,098 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:10,098 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 508 bytes
2013-10-23 22:40:10,098 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,099 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:10,099 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:10,103 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2013-10-23 22:40:10,103 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count4"]
2013-10-23 22:40:10,108 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local850237118_0013_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:10,108 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,109 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local850237118_0013_r_000000_0 is allowed to commit now
2013-10-23 22:40:10,110 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local850237118_0013_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count4
2013-10-23 22:40:10,111 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:10,111 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local850237118_0013_r_000000_0' done.
2013-10-23 22:40:10,122 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/count4/_temporary
2013-10-23 22:40:10,130 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,137 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,138 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/count4
2013-10-23 22:40:10,144 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:10,144 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filter"]
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:10,152 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:10,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2013-10-23 22:40:10,160 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,176 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local1087442898_0014
2013-10-23 22:40:10,177 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:10,178 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1087442898_0014_m_000000_0
2013-10-23 22:40:10,179 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:10,179 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:10,180 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3acff49f
2013-10-23 22:40:10,180 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 22:40:10,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:10,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:10,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:10,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filter"]
2013-10-23 22:40:10,190 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1087442898_0014_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:10,192 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,192 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1087442898_0014_m_000000_0 is allowed to commit now
2013-10-23 22:40:10,193 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1087442898_0014_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filter
2013-10-23 22:40:10,194 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:10,194 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1087442898_0014_m_000000_0' done.
2013-10-23 22:40:10,194 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1087442898_0014_m_000000_0
2013-10-23 22:40:10,194 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:10,199 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/filter/_temporary
2013-10-23 22:40:10,205 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,205 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/filter
2013-10-23 22:40:10,211 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 22:40:10,211 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /Users/jwfbean/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-23 22:40:10,228 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-23 22:40:10,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:10,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simple"]
2013-10-23 22:40:10,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-23 22:40:10,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-23 22:40:10,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-23 22:40:10,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2013-10-23 22:40:10,238 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,256 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local121107471_0015
2013-10-23 22:40:10,257 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 22:40:10,258 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local121107471_0015_m_000000_0
2013-10-23 22:40:10,258 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:10,260 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt
2013-10-23 22:40:10,260 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@76340c9c
2013-10-23 22:40:10,260 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2013-10-23 22:40:10,261 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2013-10-23 22:40:10,273 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2013-10-23 22:40:10,273 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2013-10-23 22:40:10,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 22:40:10,274 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 22:40:10,280 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt"]
2013-10-23 22:40:10,280 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:10,281 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2013-10-23 22:40:10,283 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2013-10-23 22:40:10,285 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local121107471_0015_m_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:10,286 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/apache.10.txt:0+1449
2013-10-23 22:40:10,286 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local121107471_0015_m_000000_0' done.
2013-10-23 22:40:10,287 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local121107471_0015_m_000000_0
2013-10-23 22:40:10,287 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 22:40:10,289 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-23 22:40:10,289 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,290 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2013-10-23 22:40:10,290 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 232 bytes
2013-10-23 22:40:10,290 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-23 22:40:10,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-23 22:40:10,296 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2013-10-23 22:40:10,296 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simple"]
2013-10-23 22:40:10,301 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local121107471_0015_r_000000_0 is done. And is in the process of commiting
2013-10-23 22:40:10,302 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-10-23 22:40:10,302 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local121107471_0015_r_000000_0 is allowed to commit now
2013-10-23 22:40:10,304 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local121107471_0015_r_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simple
2013-10-23 22:40:10,305 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2013-10-23 22:40:10,305 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local121107471_0015_r_000000_0' done.
2013-10-23 22:40:10,312 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/basicpipesplatform/simple/_temporary
2013-10-23 22:40:10,317 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 22:40:10,318 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/basicpipesplatform/simple