Class cascading.detail.EachEachPipeAssemblyPlatformTest

all > cascading.detail > EachEachPipeAssemblyPlatformTest
tests
failures
3.405s
duration
100%
successful
Tests
Standard output
Tests

Test	Duration	Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop]	0.130s	passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop]	0.162s	passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop]	0.776s	passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop]	0.112s	passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop]	0.122s	passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop]	0.013s	passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop]	0.012s	passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop]	0.104s	passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop]	0.093s	passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop]	0.013s	passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop]	0.105s	passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop]	0.078s	passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop]	0.102s	passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop]	0.014s	passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop]	0.080s	passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop]	0.073s	passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop]	0.068s	passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop]	0.083s	passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop]	0.095s	passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop]	0.082s	passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop]	0.090s	passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop]	0.007s	passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop]	0.072s	passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop]	0.007s	passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop]	0.069s	passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop]	0.009s	passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop]	0.075s	passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop]	0.075s	passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop]	0.075s	passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop]	0.009s	passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop]	0.055s	passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop]	0.058s	passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop]	0.068s	passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop]	0.070s	passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop]	0.065s	passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop]	0.070s	passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop]	0.065s	passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop]	0.066s	passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop]	0.007s	passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop]	0.076s	passed
Standard output

2013-10-23 23:22:32,656 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-23 23:22:32,671 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-23 23:22:32,671 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2013-10-23 23:22:32,694 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,704 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,711 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,716 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,721 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,726 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,730 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,731 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,734 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,737 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,740 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,740 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,740 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,742 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,742 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,743 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,746 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,746 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,750 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,756 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,760 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,764 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,768 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,768 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,772 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,775 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,776 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,776 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,776 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,777 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,780 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,781 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,783 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,783 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,785 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,788 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,790 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,792 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,795 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,798 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-23 23:22:32,901 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-23 23:22:33,165 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:33,166 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 23:22:33,173 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 122988AF120D45FAAE6CF5E8277B2369
2013-10-23 23:22:33,292 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-23 23:22:33,294 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:33,294 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,295 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-23 23:22:33,295 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:33,295 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:33,295 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:33,297 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2013-10-23 23:22:33,320 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 23:22:33,361 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-10-23 23:22:33,366 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,503 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local658883311_0001
2013-10-23 23:22:33,521 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:33,523 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local658883311_0001_m_000000_0
2013-10-23 23:22:33,552 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:33,555 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:33,556 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3970ae0
2013-10-23 23:22:33,560 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:33,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:33,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:33,604 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,605 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-23 23:22:33,612 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local658883311_0001_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:33,615 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:33,616 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local658883311_0001_m_000000_0 is allowed to commit now
2013-10-23 23:22:33,619 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local658883311_0001_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-23 23:22:33,620 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:33,620 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local658883311_0001_m_000000_0' done.
2013-10-23 23:22:33,620 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local658883311_0001_m_000000_0
2013-10-23 23:22:33,620 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:33,636 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2013-10-23 23:22:33,659 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,675 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,677 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-23 23:22:33,690 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:33,691 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 23:22:33,704 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-23 23:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:33,705 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2013-10-23 23:22:33,716 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,773 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1371820323_0002
2013-10-23 23:22:33,775 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:33,775 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1371820323_0002_m_000000_0
2013-10-23 23:22:33,777 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:33,779 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:33,779 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7e913c56
2013-10-23 23:22:33,780 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:33,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:33,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:33,794 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,794 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-23 23:22:33,796 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1371820323_0002_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:33,798 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:33,798 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1371820323_0002_m_000000_0 is allowed to commit now
2013-10-23 23:22:33,800 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1371820323_0002_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-23 23:22:33,801 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:33,801 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1371820323_0002_m_000000_0' done.
2013-10-23 23:22:33,801 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1371820323_0002_m_000000_0
2013-10-23 23:22:33,802 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:33,807 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2013-10-23 23:22:33,824 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,838 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,839 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-23 23:22:33,850 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:33,850 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 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-23 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:33,865 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:33,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2013-10-23 23:22:33,881 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,917 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1038386449_0003
2013-10-23 23:22:33,920 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:33,920 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1038386449_0003_m_000000_0
2013-10-23 23:22:33,922 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:33,923 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:33,923 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2242f64e
2013-10-23 23:22:33,924 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:33,928 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:33,928 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:33,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,938 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-23 23:22:33,941 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1038386449_0003_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:33,943 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:33,943 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1038386449_0003_m_000000_0 is allowed to commit now
2013-10-23 23:22:33,946 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1038386449_0003_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-23 23:22:33,947 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:33,947 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1038386449_0003_m_000000_0' done.
2013-10-23 23:22:33,947 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1038386449_0003_m_000000_0
2013-10-23 23:22:33,947 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:33,952 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2013-10-23 23:22:33,960 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,968 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:33,969 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-23 23:22:33,976 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:33,976 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 23:22:33,988 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:33,988 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:33,988 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-23 23:22:33,989 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:33,989 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:33,989 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:33,989 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2013-10-23 23:22:34,001 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,037 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local481915273_0004
2013-10-23 23:22:34,039 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,039 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local481915273_0004_m_000000_0
2013-10-23 23:22:34,041 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,042 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,043 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@673a95af
2013-10-23 23:22:34,044 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,049 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,049 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,059 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-23 23:22:34,061 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local481915273_0004_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,062 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,062 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local481915273_0004_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,065 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local481915273_0004_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-23 23:22:34,066 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,067 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local481915273_0004_m_000000_0' done.
2013-10-23 23:22:34,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local481915273_0004_m_000000_0
2013-10-23 23:22:34,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,071 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2013-10-23 23:22:34,079 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,090 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,092 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-23 23:22:34,102 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,102 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 23:22:34,114 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,115 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,115 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-23 23:22:34,115 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,115 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,115 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,115 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2013-10-23 23:22:34,125 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,150 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local855887212_0005
2013-10-23 23:22:34,151 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,152 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local855887212_0005_m_000000_0
2013-10-23 23:22:34,153 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,154 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,154 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@35a271f5
2013-10-23 23:22:34,155 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,158 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,158 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,164 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-23 23:22:34,166 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local855887212_0005_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,167 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,167 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local855887212_0005_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,169 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local855887212_0005_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-23 23:22:34,170 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,170 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local855887212_0005_m_000000_0' done.
2013-10-23 23:22:34,170 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local855887212_0005_m_000000_0
2013-10-23 23:22:34,171 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,185 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2013-10-23 23:22:34,195 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,204 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,205 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-23 23:22:34,212 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,213 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 23:22:34,224 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,225 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,225 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-23 23:22:34,225 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,225 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,225 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,226 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2013-10-23 23:22:34,235 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,258 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1867555302_0006
2013-10-23 23:22:34,260 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,260 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1867555302_0006_m_000000_0
2013-10-23 23:22:34,261 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,262 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,262 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@12b9b67b
2013-10-23 23:22:34,263 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,265 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,265 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,272 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-23 23:22:34,275 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1867555302_0006_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,277 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,277 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1867555302_0006_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,282 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1867555302_0006_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-23 23:22:34,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,283 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1867555302_0006_m_000000_0' done.
2013-10-23 23:22:34,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1867555302_0006_m_000000_0
2013-10-23 23:22:34,284 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,294 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2013-10-23 23:22:34,301 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,309 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,311 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-23 23:22:34,317 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,318 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 23:22:34,324 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2013-10-23 23:22:34,331 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,332 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 23:22:34,343 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-23 23:22:34,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,345 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2013-10-23 23:22:34,353 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,376 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local154491781_0007
2013-10-23 23:22:34,378 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,378 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local154491781_0007_m_000000_0
2013-10-23 23:22:34,379 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,380 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,380 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2a5b8e8c
2013-10-23 23:22:34,381 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,383 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,383 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,389 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,389 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-23 23:22:34,391 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local154491781_0007_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,393 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,393 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local154491781_0007_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,395 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local154491781_0007_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-23 23:22:34,395 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,396 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local154491781_0007_m_000000_0' done.
2013-10-23 23:22:34,396 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local154491781_0007_m_000000_0
2013-10-23 23:22:34,396 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,399 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2013-10-23 23:22:34,408 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,417 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,418 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-23 23:22:34,424 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,425 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 23:22:34,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-23 23:22:34,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,436 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2013-10-23 23:22:34,444 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,469 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1972598049_0008
2013-10-23 23:22:34,471 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,471 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1972598049_0008_m_000000_0
2013-10-23 23:22:34,472 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,473 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,473 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@43886a34
2013-10-23 23:22:34,474 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,477 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,477 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,483 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,484 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-23 23:22:34,486 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1972598049_0008_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,487 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,487 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1972598049_0008_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,489 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1972598049_0008_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-23 23:22:34,490 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,490 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1972598049_0008_m_000000_0' done.
2013-10-23 23:22:34,490 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1972598049_0008_m_000000_0
2013-10-23 23:22:34,490 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,503 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2013-10-23 23:22:34,510 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,519 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,520 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-23 23:22:34,526 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,526 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 23:22:34,535 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,536 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,536 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-23 23:22:34,536 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,536 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,536 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2013-10-23 23:22:34,544 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1931697349_0009
2013-10-23 23:22:34,562 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,562 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1931697349_0009_m_000000_0
2013-10-23 23:22:34,563 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,564 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,564 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2d1b99c4
2013-10-23 23:22:34,565 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,573 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-23 23:22:34,575 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1931697349_0009_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,577 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,577 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1931697349_0009_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,579 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1931697349_0009_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-23 23:22:34,580 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,580 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1931697349_0009_m_000000_0' done.
2013-10-23 23:22:34,580 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1931697349_0009_m_000000_0
2013-10-23 23:22:34,580 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,584 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2013-10-23 23:22:34,590 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,597 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,598 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-23 23:22:34,603 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,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 23:22:34,615 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,615 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,615 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-23 23:22:34,616 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,616 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,616 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,616 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-23 23:22:34,624 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1519318555_0010
2013-10-23 23:22:34,643 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,643 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1519318555_0010_m_000000_0
2013-10-23 23:22:34,645 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,646 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,646 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@40dec87
2013-10-23 23:22:34,647 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,650 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,651 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,659 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,659 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-23 23:22:34,660 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,662 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,663 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,664 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,665 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1519318555_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,676 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:34,676 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:34,676 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:34,676 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-23 23:22:34,677 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:34,677 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2013-10-23 23:22:34,677 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2013-10-23 23:22:34,686 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,687 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 23:22:34,692 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2013-10-23 23:22:34,698 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,699 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 23:22:34,708 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,709 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,709 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-23 23:22:34,709 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,709 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,709 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,710 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-23 23:22:34,718 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,737 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1476890372_0011
2013-10-23 23:22:34,738 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,738 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1476890372_0011_m_000000_0
2013-10-23 23:22:34,740 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,741 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,741 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@13af9d1c
2013-10-23 23:22:34,742 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,745 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,746 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,752 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-23 23:22:34,753 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,754 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,754 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,756 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,757 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1476890372_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,759 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:34,759 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:34,760 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:34,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-23 23:22:34,760 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:34,760 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2013-10-23 23:22:34,760 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2013-10-23 23:22:34,769 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,769 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 23:22:34,783 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,784 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,784 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-23 23:22:34,784 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,784 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,784 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,785 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-23 23:22:34,793 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,810 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1311535025_0012
2013-10-23 23:22:34,812 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,812 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1311535025_0012_m_000000_0
2013-10-23 23:22:34,813 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,814 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,814 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3082f392
2013-10-23 23:22:34,815 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,817 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,818 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,823 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,824 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-23 23:22:34,824 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,825 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,826 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,827 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,828 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1311535025_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:34,833 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:34,833 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:34,833 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:34,833 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-23 23:22:34,833 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:34,834 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2013-10-23 23:22:34,834 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2013-10-23 23:22:34,843 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,843 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 23:22:34,848 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2013-10-23 23:22:34,856 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,857 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 23:22:34,868 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,869 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,869 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-23 23:22:34,869 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,869 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,870 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,870 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2013-10-23 23:22:34,879 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,898 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1055296188_0013
2013-10-23 23:22:34,900 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:34,900 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1055296188_0013_m_000000_0
2013-10-23 23:22:34,901 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:34,902 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:34,902 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@21ff3fcf
2013-10-23 23:22:34,903 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:34,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:34,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:34,914 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,914 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-23 23:22:34,916 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1055296188_0013_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:34,917 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:34,918 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1055296188_0013_m_000000_0 is allowed to commit now
2013-10-23 23:22:34,920 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1055296188_0013_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-23 23:22:34,920 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:34,921 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1055296188_0013_m_000000_0' done.
2013-10-23 23:22:34,921 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1055296188_0013_m_000000_0
2013-10-23 23:22:34,921 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:34,932 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2013-10-23 23:22:34,941 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,951 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:34,952 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-23 23:22:34,961 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,961 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 23:22:34,964 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2013-10-23 23:22:34,970 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:34,970 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 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-23 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:34,979 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:34,980 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2013-10-23 23:22:34,989 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,009 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1501311478_0014
2013-10-23 23:22:35,011 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,011 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1501311478_0014_m_000000_0
2013-10-23 23:22:35,013 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,014 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,014 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@456999c8
2013-10-23 23:22:35,015 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,025 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,025 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-23 23:22:35,028 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1501311478_0014_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,029 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,030 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1501311478_0014_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,032 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1501311478_0014_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-23 23:22:35,033 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,033 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1501311478_0014_m_000000_0' done.
2013-10-23 23:22:35,034 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1501311478_0014_m_000000_0
2013-10-23 23:22:35,034 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,043 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2013-10-23 23:22:35,050 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,059 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,060 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-23 23:22:35,067 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,067 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 23:22:35,075 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-23 23:22:35,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,076 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,076 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2013-10-23 23:22:35,083 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,104 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1458228990_0015
2013-10-23 23:22:35,105 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,105 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1458228990_0015_m_000000_0
2013-10-23 23:22:35,106 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,107 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,107 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1704ebb
2013-10-23 23:22:35,108 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,110 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,110 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,115 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-23 23:22:35,118 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1458228990_0015_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,119 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,119 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1458228990_0015_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,121 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1458228990_0015_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-23 23:22:35,122 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,122 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1458228990_0015_m_000000_0' done.
2013-10-23 23:22:35,122 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1458228990_0015_m_000000_0
2013-10-23 23:22:35,122 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,127 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2013-10-23 23:22:35,133 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,141 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,143 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-23 23:22:35,151 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,151 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 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-23 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,160 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,161 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2013-10-23 23:22:35,167 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,183 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1700141906_0016
2013-10-23 23:22:35,185 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,185 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1700141906_0016_m_000000_0
2013-10-23 23:22:35,186 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,188 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,188 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@47004b78
2013-10-23 23:22:35,189 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,193 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,200 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-23 23:22:35,202 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1700141906_0016_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,203 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,203 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1700141906_0016_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,205 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1700141906_0016_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-23 23:22:35,206 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,206 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1700141906_0016_m_000000_0' done.
2013-10-23 23:22:35,206 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1700141906_0016_m_000000_0
2013-10-23 23:22:35,207 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,218 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2013-10-23 23:22:35,224 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,231 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,233 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-23 23:22:35,241 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,241 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 23:22:35,249 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,249 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,250 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-23 23:22:35,250 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,250 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,250 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,250 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2013-10-23 23:22:35,256 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,278 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1569746531_0017
2013-10-23 23:22:35,280 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,280 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1569746531_0017_m_000000_0
2013-10-23 23:22:35,281 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,282 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,282 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@207c15c0
2013-10-23 23:22:35,283 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,286 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,291 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-23 23:22:35,294 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1569746531_0017_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,295 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,295 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1569746531_0017_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,297 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1569746531_0017_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-23 23:22:35,298 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,298 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1569746531_0017_m_000000_0' done.
2013-10-23 23:22:35,298 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1569746531_0017_m_000000_0
2013-10-23 23:22:35,298 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2013-10-23 23:22:35,307 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,314 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,314 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-23 23:22:35,319 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,320 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 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-23 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,331 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,332 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2013-10-23 23:22:35,338 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,354 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local411034340_0018
2013-10-23 23:22:35,356 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,356 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local411034340_0018_m_000000_0
2013-10-23 23:22:35,357 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,357 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,358 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@419829a9
2013-10-23 23:22:35,359 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,360 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,360 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,365 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,365 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-23 23:22:35,367 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local411034340_0018_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,369 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,369 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local411034340_0018_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,371 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local411034340_0018_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-23 23:22:35,372 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,372 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local411034340_0018_m_000000_0' done.
2013-10-23 23:22:35,373 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local411034340_0018_m_000000_0
2013-10-23 23:22:35,373 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,377 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2013-10-23 23:22:35,383 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,389 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,390 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-23 23:22:35,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,396 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 23:22:35,398 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2013-10-23 23:22:35,405 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,405 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 23:22:35,413 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,413 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,413 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-23 23:22:35,414 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,414 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,414 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2013-10-23 23:22:35,422 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,437 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local408014397_0019
2013-10-23 23:22:35,438 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,439 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local408014397_0019_m_000000_0
2013-10-23 23:22:35,440 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,440 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,440 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@21780f30
2013-10-23 23:22:35,441 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,448 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-23 23:22:35,450 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local408014397_0019_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,451 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,451 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local408014397_0019_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,454 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local408014397_0019_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-23 23:22:35,455 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,455 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local408014397_0019_m_000000_0' done.
2013-10-23 23:22:35,455 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local408014397_0019_m_000000_0
2013-10-23 23:22:35,455 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,460 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2013-10-23 23:22:35,466 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,473 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,474 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-23 23:22:35,479 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,479 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 23:22:35,486 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,487 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,487 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-23 23:22:35,487 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,487 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,487 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,488 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2013-10-23 23:22:35,493 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,512 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1290774707_0020
2013-10-23 23:22:35,513 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,513 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1290774707_0020_m_000000_0
2013-10-23 23:22:35,514 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,514 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,515 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2a871dcc
2013-10-23 23:22:35,515 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,521 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,521 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-23 23:22:35,523 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1290774707_0020_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,524 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,524 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1290774707_0020_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,526 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1290774707_0020_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-23 23:22:35,527 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,527 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1290774707_0020_m_000000_0' done.
2013-10-23 23:22:35,527 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1290774707_0020_m_000000_0
2013-10-23 23:22:35,527 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,535 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2013-10-23 23:22:35,542 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,549 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,549 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-23 23:22:35,554 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,555 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 23:22:35,560 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,560 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,560 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-23 23:22:35,561 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,561 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,561 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-23 23:22:35,567 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,582 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1132371377_0021
2013-10-23 23:22:35,583 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,583 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1132371377_0021_m_000000_0
2013-10-23 23:22:35,584 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,585 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,585 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2e78b4c4
2013-10-23 23:22:35,586 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,592 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-23 23:22:35,593 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,593 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,594 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,595 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,596 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1132371377_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,604 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:35,604 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:35,604 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:35,604 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-23 23:22:35,604 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:35,605 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2013-10-23 23:22:35,605 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2013-10-23 23:22:35,611 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,612 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 23:22:35,614 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2013-10-23 23:22:35,619 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,619 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 23:22:35,624 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,625 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,625 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-23 23:22:35,625 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,625 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,625 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,625 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-23 23:22:35,631 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,659 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1845936357_0022
2013-10-23 23:22:35,660 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,661 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1845936357_0022_m_000000_0
2013-10-23 23:22:35,661 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,662 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,662 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@281827c9
2013-10-23 23:22:35,663 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,669 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-23 23:22:35,669 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,669 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,670 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,671 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,672 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1845936357_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,681 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:35,681 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:35,681 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:35,681 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-23 23:22:35,681 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:35,682 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2013-10-23 23:22:35,682 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2013-10-23 23:22:35,687 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,687 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 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-23 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,693 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,693 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-23 23:22:35,700 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,717 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local322301378_0023
2013-10-23 23:22:35,718 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,718 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local322301378_0023_m_000000_0
2013-10-23 23:22:35,719 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,720 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,720 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@65c0035b
2013-10-23 23:22:35,720 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,726 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,726 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-23 23:22:35,727 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,727 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,728 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,729 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,730 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local322301378_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:680)
2013-10-23 23:22:35,739 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-23 23:22:35,739 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-23 23:22:35,740 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-23 23:22:35,740 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-23 23:22:35,740 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-23 23:22:35,740 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2013-10-23 23:22:35,740 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2013-10-23 23:22:35,747 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,748 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 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-23 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,755 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2013-10-23 23:22:35,761 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,777 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1963085492_0024
2013-10-23 23:22:35,778 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,778 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1963085492_0024_m_000000_0
2013-10-23 23:22:35,779 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,780 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,780 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7a49182
2013-10-23 23:22:35,781 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,787 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,787 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-23 23:22:35,789 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1963085492_0024_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,790 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,790 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1963085492_0024_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,791 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1963085492_0024_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-23 23:22:35,792 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,793 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1963085492_0024_m_000000_0' done.
2013-10-23 23:22:35,793 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1963085492_0024_m_000000_0
2013-10-23 23:22:35,793 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,800 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2013-10-23 23:22:35,806 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,812 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,813 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-23 23:22:35,818 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,818 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 23:22:35,820 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2013-10-23 23:22:35,825 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,825 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 23:22:35,831 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,831 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,831 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-23 23:22:35,832 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,832 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,832 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,832 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2013-10-23 23:22:35,839 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,854 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1113652435_0025
2013-10-23 23:22:35,855 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,855 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1113652435_0025_m_000000_0
2013-10-23 23:22:35,856 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,857 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,857 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@58e50f2c
2013-10-23 23:22:35,858 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,859 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,859 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,863 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,863 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-23 23:22:35,865 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1113652435_0025_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,866 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,866 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1113652435_0025_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,867 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1113652435_0025_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-23 23:22:35,868 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,868 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1113652435_0025_m_000000_0' done.
2013-10-23 23:22:35,868 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1113652435_0025_m_000000_0
2013-10-23 23:22:35,868 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,877 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2013-10-23 23:22:35,882 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,888 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,889 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-23 23:22:35,894 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,894 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 23:22:35,896 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2013-10-23 23:22:35,900 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,901 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 23:22:35,906 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,906 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,907 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-23 23:22:35,907 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,907 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,907 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,907 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2013-10-23 23:22:35,917 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,931 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local549652448_0026
2013-10-23 23:22:35,932 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,932 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local549652448_0026_m_000000_0
2013-10-23 23:22:35,933 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,934 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,934 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5a6b258d
2013-10-23 23:22:35,934 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:35,936 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:35,936 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:35,940 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,940 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-23 23:22:35,941 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local549652448_0026_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:35,942 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:35,942 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local549652448_0026_m_000000_0 is allowed to commit now
2013-10-23 23:22:35,944 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local549652448_0026_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-23 23:22:35,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:35,945 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local549652448_0026_m_000000_0' done.
2013-10-23 23:22:35,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local549652448_0026_m_000000_0
2013-10-23 23:22:35,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:35,954 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2013-10-23 23:22:35,959 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,965 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,966 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-23 23:22:35,971 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:35,971 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 23:22:35,976 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:35,977 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:35,977 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-23 23:22:35,977 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:35,977 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:35,977 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:35,977 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2013-10-23 23:22:35,983 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:35,996 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local731661893_0027
2013-10-23 23:22:35,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:35,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local731661893_0027_m_000000_0
2013-10-23 23:22:35,998 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:35,998 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:35,999 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@29df2ecc
2013-10-23 23:22:35,999 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:36,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:36,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:36,005 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,005 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-23 23:22:36,007 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local731661893_0027_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:36,008 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:36,008 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local731661893_0027_m_000000_0 is allowed to commit now
2013-10-23 23:22:36,009 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local731661893_0027_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-23 23:22:36,010 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:36,010 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local731661893_0027_m_000000_0' done.
2013-10-23 23:22:36,010 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local731661893_0027_m_000000_0
2013-10-23 23:22:36,010 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:36,018 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2013-10-23 23:22:36,024 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,030 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,031 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-23 23:22:36,037 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:36,037 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 23:22:36,043 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:36,043 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,043 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-23 23:22:36,043 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:36,043 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:36,044 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:36,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2013-10-23 23:22:36,051 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,066 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local477675858_0028
2013-10-23 23:22:36,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:36,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local477675858_0028_m_000000_0
2013-10-23 23:22:36,068 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:36,069 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:36,069 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@30d8f246
2013-10-23 23:22:36,069 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:36,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:36,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:36,075 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,075 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-23 23:22:36,076 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local477675858_0028_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:36,078 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:36,078 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local477675858_0028_m_000000_0 is allowed to commit now
2013-10-23 23:22:36,080 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local477675858_0028_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-23 23:22:36,081 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:36,081 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local477675858_0028_m_000000_0' done.
2013-10-23 23:22:36,081 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local477675858_0028_m_000000_0
2013-10-23 23:22:36,081 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:36,089 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2013-10-23 23:22:36,094 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,100 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,101 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-23 23:22:36,105 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:36,106 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 23:22:36,111 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:36,111 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-23 23:22:36,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:36,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:36,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:36,112 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2013-10-23 23:22:36,117 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local755227269_0029
2013-10-23 23:22:36,131 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:36,131 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local755227269_0029_m_000000_0
2013-10-23 23:22:36,132 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:36,133 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:36,133 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@23ccf0ad
2013-10-23 23:22:36,134 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:36,136 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:36,136 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:36,140 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,140 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-23 23:22:36,142 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local755227269_0029_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:36,142 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:36,143 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local755227269_0029_m_000000_0 is allowed to commit now
2013-10-23 23:22:36,144 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local755227269_0029_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-23 23:22:36,145 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:36,145 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local755227269_0029_m_000000_0' done.
2013-10-23 23:22:36,145 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local755227269_0029_m_000000_0
2013-10-23 23:22:36,145 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:36,155 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2013-10-23 23:22:36,160 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,166 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-23 23:22:36,171 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:36,171 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 23:22:36,177 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:36,177 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,177 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-23 23:22:36,177 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:36,178 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:36,178 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:36,178 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2013-10-23 23:22:36,183 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,196 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1125607966_0030
2013-10-23 23:22:36,197 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:36,197 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1125607966_0030_m_000000_0
2013-10-23 23:22:36,198 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:36,199 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:36,199 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@53cc48dd
2013-10-23 23:22:36,199 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:36,201 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:36,201 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:36,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,204 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-23 23:22:36,206 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1125607966_0030_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:36,207 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:36,207 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1125607966_0030_m_000000_0 is allowed to commit now
2013-10-23 23:22:36,208 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1125607966_0030_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-23 23:22:36,211 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:36,211 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1125607966_0030_m_000000_0' done.
2013-10-23 23:22:36,211 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1125607966_0030_m_000000_0
2013-10-23 23:22:36,211 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:36,219 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2013-10-23 23:22:36,225 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,231 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,232 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-23 23:22:36,236 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:36,236 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 23:22:36,241 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-23 23:22:36,242 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,242 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-23 23:22:36,242 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-23 23:22:36,242 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-23 23:22:36,242 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-23 23:22:36,243 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2013-10-23 23:22:36,249 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,273 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local355545606_0031
2013-10-23 23:22:36,274 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-10-23 23:22:36,274 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local355545606_0031_m_000000_0
2013-10-23 23:22:36,275 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-23 23:22:36,276 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt
2013-10-23 23:22:36,276 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1de9f2e2
2013-10-23 23:22:36,277 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-10-23 23:22:36,278 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-23 23:22:36,278 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-23 23:22:36,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt"]
2013-10-23 23:22:36,282 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/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-23 23:22:36,284 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local355545606_0031_m_000000_0 is done. And is in the process of commiting
2013-10-23 23:22:36,285 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-10-23 23:22:36,285 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local355545606_0031_m_000000_0 is allowed to commit now
2013-10-23 23:22:36,287 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local355545606_0031_m_000000_0' to file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-23 23:22:36,289 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/classes/test/data/nums.20.txt:0+51
2013-10-23 23:22:36,289 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local355545606_0031_m_000000_0' done.
2013-10-23 23:22:36,289 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local355545606_0031_m_000000_0
2013-10-23 23:22:36,289 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-10-23 23:22:36,296 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2013-10-23 23:22:36,301 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,307 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-23 23:22:36,307 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-23 23:22:36,312 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-23 23:22:36,313 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 23:22:36,315 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/jwfbean/git/cascading.compatibility/cloudera-cdh4.4/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'