2014-04-09 19:48:32,922 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2014-04-09 19:48:32,940 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2014-04-09 19:48:32,940 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2014-04-09 19:48:32,955 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,963 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,968 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,972 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,976 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,979 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,982 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,983 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,985 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,987 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,990 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,990 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,990 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,991 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,992 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,992 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,994 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,995 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:32,997 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,000 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,003 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,005 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,007 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,007 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,009 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,011 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,011 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,012 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,012 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,012 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,014 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,014 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,016 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,016 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,018 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,020 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,023 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,024 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,026 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,028 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2014-04-09 19:48:33,095 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2014-04-09 19:48:33,249 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:33,250 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:33,256 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 753A0CFD9C634BCEBA53EBC48B01B4FE
2014-04-09 19:48:33,352 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.5.3
2014-04-09 19:48:33,353 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:33,354 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:33,354 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2014-04-09 19:48:33,354 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:33,355 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:33,355 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:33,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2014-04-09 19:48:33,375 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-04-09 19:48:33,395 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2014-04-09 19:48:33,396 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:33,489 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0001
2014-04-09 19:48:33,489 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:33,522 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2014-04-09 19:48:33,525 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@613fbf92
2014-04-09 19:48:33,532 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:33,538 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:33,544 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:33,544 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:33,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:33,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2014-04-09 19:48:33,583 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:33,585 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:33,585 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2014-04-09 19:48:33,588 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2014-04-09 19:48:36,516 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:36,517 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2014-04-09 19:48:36,529 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2014-04-09 19:48:36,547 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:36,560 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:36,561 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2014-04-09 19:48:36,572 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:36,572 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:36,584 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:36,585 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:36,585 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2014-04-09 19:48:36,585 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:36,585 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:36,585 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:36,586 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2014-04-09 19:48:36,592 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:36,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0002
2014-04-09 19:48:36,630 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:36,632 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@17b18d5e
2014-04-09 19:48:36,633 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:36,633 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:36,635 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:36,635 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:36,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:36,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2014-04-09 19:48:36,644 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:36,644 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:36,645 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2014-04-09 19:48:36,647 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2014-04-09 19:48:39,632 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:39,633 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2014-04-09 19:48:39,648 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2014-04-09 19:48:39,669 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:39,680 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:39,681 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2014-04-09 19:48:39,691 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:39,692 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:39,703 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:39,703 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:39,703 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2014-04-09 19:48:39,704 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:39,704 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:39,704 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:39,704 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2014-04-09 19:48:39,714 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:39,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0003
2014-04-09 19:48:39,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:39,757 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@45ce49c9
2014-04-09 19:48:39,758 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:39,758 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:39,761 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:39,761 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:39,767 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:39,767 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2014-04-09 19:48:39,769 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:39,769 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:39,770 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2014-04-09 19:48:39,771 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2014-04-09 19:48:42,757 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:42,758 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2014-04-09 19:48:42,773 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2014-04-09 19:48:42,784 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:42,791 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:42,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2014-04-09 19:48:42,797 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:42,798 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:42,807 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2014-04-09 19:48:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:42,808 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:42,808 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2014-04-09 19:48:42,815 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:42,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0004
2014-04-09 19:48:42,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:42,833 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4b8bc03c
2014-04-09 19:48:42,835 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:42,836 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:42,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:42,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:42,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:42,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2014-04-09 19:48:42,845 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:42,846 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:42,846 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2014-04-09 19:48:42,848 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2014-04-09 19:48:45,833 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:45,834 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2014-04-09 19:48:45,848 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2014-04-09 19:48:45,859 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:45,865 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:45,866 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2014-04-09 19:48:45,871 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:45,872 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:45,881 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:45,882 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:45,882 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2014-04-09 19:48:45,882 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:45,882 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:45,882 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:45,883 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2014-04-09 19:48:45,892 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:45,907 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0005
2014-04-09 19:48:45,907 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:45,910 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@33e5c671
2014-04-09 19:48:45,910 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:45,911 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:45,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:45,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:45,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:45,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2014-04-09 19:48:45,921 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:45,921 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:45,922 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2014-04-09 19:48:45,924 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2014-04-09 19:48:48,910 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:48,911 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2014-04-09 19:48:48,925 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2014-04-09 19:48:48,936 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:48,942 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:48,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2014-04-09 19:48:48,947 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:48,948 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:48,957 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:48,957 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:48,958 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2014-04-09 19:48:48,958 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:48,958 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:48,958 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:48,959 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2014-04-09 19:48:48,970 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:48,985 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0006
2014-04-09 19:48:48,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:48,989 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6d9a661b
2014-04-09 19:48:48,989 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:48,990 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:48,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:48,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:48,997 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:48,997 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2014-04-09 19:48:48,999 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:48,999 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:49,000 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2014-04-09 19:48:49,001 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2014-04-09 19:48:51,989 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:51,990 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2014-04-09 19:48:52,004 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2014-04-09 19:48:52,012 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:52,017 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:52,017 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2014-04-09 19:48:52,022 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:52,022 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:52,025 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2014-04-09 19:48:52,029 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:52,029 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:52,038 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:52,039 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:52,039 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2014-04-09 19:48:52,039 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:52,040 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:52,040 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:52,041 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2014-04-09 19:48:52,050 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:52,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0007
2014-04-09 19:48:52,064 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:52,067 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@444eaac
2014-04-09 19:48:52,068 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:52,069 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:52,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:52,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:52,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:52,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2014-04-09 19:48:52,079 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:52,080 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:52,080 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2014-04-09 19:48:52,082 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2014-04-09 19:48:55,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:55,068 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2014-04-09 19:48:55,071 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2014-04-09 19:48:55,081 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:55,091 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:55,092 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2014-04-09 19:48:55,097 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:55,097 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:55,106 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2014-04-09 19:48:55,107 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:55,107 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:55,107 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:55,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2014-04-09 19:48:55,116 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:55,129 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0008
2014-04-09 19:48:55,129 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:55,133 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7250617b
2014-04-09 19:48:55,134 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:55,136 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:55,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:55,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:55,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:55,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2014-04-09 19:48:55,144 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:55,145 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:55,145 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2014-04-09 19:48:55,146 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2014-04-09 19:48:58,132 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:48:58,133 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2014-04-09 19:48:58,147 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2014-04-09 19:48:58,152 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:58,157 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:58,158 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2014-04-09 19:48:58,161 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:48:58,162 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:48:58,170 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:48:58,170 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:58,170 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2014-04-09 19:48:58,170 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:48:58,171 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:48:58,171 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:48:58,171 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2014-04-09 19:48:58,179 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:48:58,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0009
2014-04-09 19:48:58,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:48:58,193 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@404f39a3
2014-04-09 19:48:58,193 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:48:58,194 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:48:58,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:48:58,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:48:58,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:48:58,200 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2014-04-09 19:48:58,202 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:48:58,202 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:48:58,202 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_m_000000_0 is allowed to commit now
2014-04-09 19:48:58,204 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2014-04-09 19:49:01,193 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:01,194 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2014-04-09 19:49:01,199 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2014-04-09 19:49:01,211 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,219 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,219 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2014-04-09 19:49:01,223 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,223 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,231 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:01,231 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,232 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2014-04-09 19:49:01,232 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:01,232 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:01,232 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:01,233 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2014-04-09 19:49:01,238 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,248 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0010
2014-04-09 19:49:01,249 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:01,250 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2c3c5ba6
2014-04-09 19:49:01,251 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:01,251 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:01,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:01,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:01,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,258 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2014-04-09 19:49:01,258 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,260 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,260 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,261 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0010 state at FAILED
2014-04-09 19:49:01,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:01,270 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:01,270 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:01,271 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:01,271 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2014-04-09 19:49:01,271 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:01,271 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2014-04-09 19:49:01,271 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2014-04-09 19:49:01,276 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,276 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,279 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2014-04-09 19:49:01,283 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,283 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:01,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2014-04-09 19:49:01,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:01,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:01,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:01,293 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2014-04-09 19:49:01,298 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,308 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0011
2014-04-09 19:49:01,308 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:01,310 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@54843caf
2014-04-09 19:49:01,311 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:01,311 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:01,313 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:01,313 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:01,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2014-04-09 19:49:01,318 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,318 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,319 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,320 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,329 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0011 state at FAILED
2014-04-09 19:49:01,329 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:01,329 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:01,329 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:01,330 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:01,330 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2014-04-09 19:49:01,330 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:01,330 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2014-04-09 19:49:01,330 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2014-04-09 19:49:01,335 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,335 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,344 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:01,344 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,345 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2014-04-09 19:49:01,345 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:01,345 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:01,345 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:01,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2014-04-09 19:49:01,350 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,360 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0012
2014-04-09 19:49:01,361 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:01,362 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@54133ffe
2014-04-09 19:49:01,363 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:01,364 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:01,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:01,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:01,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2014-04-09 19:49:01,370 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,370 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,371 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,372 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0012
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:01,381 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0012 state at FAILED
2014-04-09 19:49:01,381 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:01,381 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:01,381 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:01,381 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:01,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2014-04-09 19:49:01,382 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:01,382 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2014-04-09 19:49:01,382 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2014-04-09 19:49:01,386 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,387 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,389 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2014-04-09 19:49:01,393 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:01,394 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:01,401 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:01,401 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,401 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2014-04-09 19:49:01,402 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:01,402 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:01,402 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:01,402 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2014-04-09 19:49:01,408 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:01,423 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0013
2014-04-09 19:49:01,424 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:01,425 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@44493280
2014-04-09 19:49:01,425 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:01,426 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:01,427 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:01,427 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:01,431 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:01,431 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2014-04-09 19:49:01,433 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:01,433 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:01,433 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_m_000000_0 is allowed to commit now
2014-04-09 19:49:01,435 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2014-04-09 19:49:04,425 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:04,426 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2014-04-09 19:49:04,432 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2014-04-09 19:49:04,440 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:04,445 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:04,445 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2014-04-09 19:49:04,449 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:04,449 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:04,452 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2014-04-09 19:49:04,455 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:04,455 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:04,462 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:04,462 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:04,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2014-04-09 19:49:04,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:04,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:04,464 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:04,465 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2014-04-09 19:49:04,470 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:04,486 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0014
2014-04-09 19:49:04,487 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:04,488 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3ae541e
2014-04-09 19:49:04,489 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:04,489 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:04,491 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:04,491 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:04,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:04,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2014-04-09 19:49:04,497 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:04,497 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:04,497 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2014-04-09 19:49:04,499 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2014-04-09 19:49:07,251 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:07,310 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:07,363 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:07,488 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:07,489 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2014-04-09 19:49:07,494 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2014-04-09 19:49:07,499 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:07,503 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:07,503 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2014-04-09 19:49:07,509 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:07,509 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:07,516 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:07,516 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:07,516 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2014-04-09 19:49:07,516 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:07,516 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:07,517 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:07,517 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2014-04-09 19:49:07,521 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:07,533 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0015
2014-04-09 19:49:07,534 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:07,536 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7bfa88e6
2014-04-09 19:49:07,537 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:07,538 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:07,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:07,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:07,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:07,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2014-04-09 19:49:07,545 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:07,554 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:07,555 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_m_000000_0 is allowed to commit now
2014-04-09 19:49:07,557 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2014-04-09 19:49:10,536 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:10,537 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2014-04-09 19:49:10,542 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2014-04-09 19:49:10,551 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:10,556 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:10,557 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2014-04-09 19:49:10,560 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:10,560 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:10,567 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:10,567 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:10,567 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2014-04-09 19:49:10,567 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:10,568 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:10,568 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:10,568 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2014-04-09 19:49:10,572 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:10,582 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0016
2014-04-09 19:49:10,582 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:10,583 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@620a6287
2014-04-09 19:49:10,584 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:10,585 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:10,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:10,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:10,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:10,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2014-04-09 19:49:10,593 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0016_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:10,593 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:10,593 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0016_m_000000_0 is allowed to commit now
2014-04-09 19:49:10,594 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2014-04-09 19:49:13,583 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:13,584 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0016_m_000000_0' done.
2014-04-09 19:49:13,590 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2014-04-09 19:49:13,598 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:13,608 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:13,609 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2014-04-09 19:49:13,612 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:13,612 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:13,619 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:13,619 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:13,620 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2014-04-09 19:49:13,620 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:13,621 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:13,621 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:13,622 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2014-04-09 19:49:13,629 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:13,638 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0017
2014-04-09 19:49:13,639 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:13,640 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5891b2c8
2014-04-09 19:49:13,640 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:13,641 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:13,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:13,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:13,645 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:13,645 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2014-04-09 19:49:13,647 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0017_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:13,648 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:13,648 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0017_m_000000_0 is allowed to commit now
2014-04-09 19:49:13,649 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2014-04-09 19:49:16,640 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:16,641 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0017_m_000000_0' done.
2014-04-09 19:49:16,646 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2014-04-09 19:49:16,655 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:16,661 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:16,661 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2014-04-09 19:49:16,665 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:16,665 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:16,671 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:16,672 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:16,672 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2014-04-09 19:49:16,672 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:16,672 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:16,672 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:16,673 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2014-04-09 19:49:16,679 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:16,688 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0018
2014-04-09 19:49:16,689 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:16,690 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@614aac1
2014-04-09 19:49:16,690 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:16,691 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:16,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:16,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:16,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:16,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2014-04-09 19:49:16,701 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0018_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:16,701 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:16,702 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0018_m_000000_0 is allowed to commit now
2014-04-09 19:49:16,702 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2014-04-09 19:49:19,690 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:19,691 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0018_m_000000_0' done.
2014-04-09 19:49:19,696 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2014-04-09 19:49:19,705 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:19,710 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:19,711 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2014-04-09 19:49:19,715 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:19,715 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:19,717 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2014-04-09 19:49:19,720 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:19,720 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:19,726 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2014-04-09 19:49:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:19,727 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:19,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2014-04-09 19:49:19,732 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:19,740 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0019
2014-04-09 19:49:19,740 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:19,741 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3cf3aa19
2014-04-09 19:49:19,742 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:19,742 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:19,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:19,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:19,747 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:19,747 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2014-04-09 19:49:19,748 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0019_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:19,748 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:19,749 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0019_m_000000_0 is allowed to commit now
2014-04-09 19:49:19,750 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0019_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2014-04-09 19:49:22,741 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:22,742 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0019_m_000000_0' done.
2014-04-09 19:49:22,748 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2014-04-09 19:49:22,756 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:22,761 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:22,762 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2014-04-09 19:49:22,765 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:22,765 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:22,771 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:22,772 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2014-04-09 19:49:22,776 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:22,785 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0020
2014-04-09 19:49:22,785 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:22,788 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3c21fd47
2014-04-09 19:49:22,789 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:22,790 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:22,792 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:22,792 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:22,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:22,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2014-04-09 19:49:22,801 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0020_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:22,801 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:22,802 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0020_m_000000_0 is allowed to commit now
2014-04-09 19:49:22,803 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0020_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2014-04-09 19:49:25,787 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:25,788 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0020_m_000000_0' done.
2014-04-09 19:49:25,793 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2014-04-09 19:49:25,800 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,804 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2014-04-09 19:49:25,808 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:25,808 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:25,814 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:25,814 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,814 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2014-04-09 19:49:25,815 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:25,815 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:25,815 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:25,815 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2014-04-09 19:49:25,821 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,829 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0021
2014-04-09 19:49:25,829 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:25,832 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@414c9fd
2014-04-09 19:49:25,833 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:25,834 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:25,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:25,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:25,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,841 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2014-04-09 19:49:25,841 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,841 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,842 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,843 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0021
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,850 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0021 state at FAILED
2014-04-09 19:49:25,851 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:25,851 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:25,851 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:25,851 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:25,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2014-04-09 19:49:25,852 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:25,852 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2014-04-09 19:49:25,852 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2014-04-09 19:49:25,861 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:25,861 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:25,865 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2014-04-09 19:49:25,870 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:25,870 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:25,876 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:25,876 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,876 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2014-04-09 19:49:25,876 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:25,877 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:25,877 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:25,877 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2014-04-09 19:49:25,880 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,888 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0022
2014-04-09 19:49:25,889 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:25,890 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@546b0add
2014-04-09 19:49:25,890 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:25,891 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:25,892 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:25,892 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:25,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,895 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2014-04-09 19:49:25,896 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,896 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,897 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,898 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0022
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,899 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0022 state at FAILED
2014-04-09 19:49:25,899 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:25,899 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:25,899 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:25,899 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:25,900 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2014-04-09 19:49:25,900 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:25,900 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2014-04-09 19:49:25,900 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2014-04-09 19:49:25,904 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:25,904 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:25,910 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:25,910 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2014-04-09 19:49:25,914 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,922 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0023
2014-04-09 19:49:25,922 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:25,923 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7fc05215
2014-04-09 19:49:25,923 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:25,924 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:25,925 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:25,925 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:25,928 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,928 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2014-04-09 19:49:25,929 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,929 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,929 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:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,930 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0023
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
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:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2014-04-09 19:49:25,932 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local_0023 state at FAILED
2014-04-09 19:49:25,932 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2014-04-09 19:49:25,932 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2014-04-09 19:49:25,932 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2014-04-09 19:49:25,933 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopping all jobs
2014-04-09 19:49:25,933 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2014-04-09 19:49:25,933 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] stopped all jobs
2014-04-09 19:49:25,933 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2014-04-09 19:49:25,933 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2014-04-09 19:49:25,937 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:25,937 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:25,943 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:25,943 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,943 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2014-04-09 19:49:25,943 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:25,943 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:25,944 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:25,944 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2014-04-09 19:49:25,947 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:25,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0024
2014-04-09 19:49:25,956 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:25,957 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@780e8e86
2014-04-09 19:49:25,957 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:25,958 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:25,959 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:25,959 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:25,962 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:25,962 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2014-04-09 19:49:25,963 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0024_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:25,964 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:25,964 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0024_m_000000_0 is allowed to commit now
2014-04-09 19:49:25,965 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0024_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2014-04-09 19:49:28,957 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:28,958 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0024_m_000000_0' done.
2014-04-09 19:49:28,963 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2014-04-09 19:49:28,971 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:28,979 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:28,979 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2014-04-09 19:49:28,982 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:28,983 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:28,984 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2014-04-09 19:49:28,987 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:28,988 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:28,993 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:28,993 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:28,994 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2014-04-09 19:49:28,994 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:28,994 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:28,994 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:28,995 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2014-04-09 19:49:29,001 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:29,011 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0025
2014-04-09 19:49:29,011 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:29,013 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@320ff7d3
2014-04-09 19:49:29,014 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:29,015 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:29,017 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:29,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:29,025 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:29,025 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2014-04-09 19:49:29,028 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0025_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:29,028 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:29,029 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0025_m_000000_0 is allowed to commit now
2014-04-09 19:49:29,029 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0025_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2014-04-09 19:49:31,832 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:31,890 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:31,924 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:32,013 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:32,014 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0025_m_000000_0' done.
2014-04-09 19:49:32,019 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2014-04-09 19:49:32,027 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:32,036 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:32,037 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2014-04-09 19:49:32,041 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:32,041 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:32,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2014-04-09 19:49:32,046 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:32,046 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:32,052 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:32,053 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2014-04-09 19:49:32,057 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:32,065 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0026
2014-04-09 19:49:32,065 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:32,067 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@55f6b8c4
2014-04-09 19:49:32,068 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:32,069 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:32,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:32,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:32,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:32,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2014-04-09 19:49:32,080 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0026_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:32,080 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:32,080 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0026_m_000000_0 is allowed to commit now
2014-04-09 19:49:32,081 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0026_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2014-04-09 19:49:35,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:35,068 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0026_m_000000_0' done.
2014-04-09 19:49:35,072 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2014-04-09 19:49:35,081 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:35,089 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:35,090 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2014-04-09 19:49:35,093 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:35,093 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:35,098 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2014-04-09 19:49:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:35,100 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2014-04-09 19:49:35,107 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:35,118 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0027
2014-04-09 19:49:35,119 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:35,120 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@29a282a1
2014-04-09 19:49:35,120 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:35,121 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:35,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:35,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:35,127 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:35,127 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2014-04-09 19:49:35,129 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0027_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:35,129 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:35,130 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0027_m_000000_0 is allowed to commit now
2014-04-09 19:49:35,131 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0027_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2014-04-09 19:49:38,120 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:38,121 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0027_m_000000_0' done.
2014-04-09 19:49:38,126 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2014-04-09 19:49:38,134 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:38,140 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:38,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2014-04-09 19:49:38,144 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:38,144 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:38,158 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:38,159 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:38,159 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2014-04-09 19:49:38,159 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:38,159 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:38,159 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:38,159 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2014-04-09 19:49:38,162 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:38,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0028
2014-04-09 19:49:38,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:38,173 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b80406e
2014-04-09 19:49:38,174 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:38,175 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:38,177 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:38,177 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:38,181 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:38,181 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2014-04-09 19:49:38,182 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0028_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:38,183 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:38,183 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0028_m_000000_0 is allowed to commit now
2014-04-09 19:49:38,184 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0028_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2014-04-09 19:49:41,173 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:41,174 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0028_m_000000_0' done.
2014-04-09 19:49:41,179 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2014-04-09 19:49:41,187 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:41,196 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:41,197 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2014-04-09 19:49:41,201 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:41,201 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:41,207 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:41,207 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:41,208 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2014-04-09 19:49:41,208 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:41,208 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:41,208 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:41,208 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2014-04-09 19:49:41,212 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:41,219 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0029
2014-04-09 19:49:41,219 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:41,220 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4f1a4a69
2014-04-09 19:49:41,221 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:41,222 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:41,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:41,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:41,229 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:41,229 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2014-04-09 19:49:41,231 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0029_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:41,231 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:41,231 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0029_m_000000_0 is allowed to commit now
2014-04-09 19:49:41,232 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0029_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2014-04-09 19:49:44,220 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:44,221 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0029_m_000000_0' done.
2014-04-09 19:49:44,227 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2014-04-09 19:49:44,235 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:44,240 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:44,241 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2014-04-09 19:49:44,244 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:44,244 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:44,249 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:44,249 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:44,250 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2014-04-09 19:49:44,250 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:44,250 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:44,250 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:44,251 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2014-04-09 19:49:44,257 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:44,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0030
2014-04-09 19:49:44,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:44,267 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3352d4
2014-04-09 19:49:44,268 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:44,269 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:44,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:44,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:44,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:44,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2014-04-09 19:49:44,274 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0030_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:44,274 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:44,274 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0030_m_000000_0 is allowed to commit now
2014-04-09 19:49:44,275 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0030_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2014-04-09 19:49:47,267 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:47,268 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0030_m_000000_0' done.
2014-04-09 19:49:47,273 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2014-04-09 19:49:47,279 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:47,283 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:47,283 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2014-04-09 19:49:47,286 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:47,286 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:47,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting
2014-04-09 19:49:47,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:47,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2014-04-09 19:49:47,292 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] parallel execution is enabled: false
2014-04-09 19:49:47,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] starting jobs: 1
2014-04-09 19:49:47,293 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [each.each] allocating threads: 1
2014-04-09 19:49:47,293 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2014-04-09 19:49:47,300 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:47,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local_0031
2014-04-09 19:49:47,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2014-04-09 19:49:47,314 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@a8b7b53
2014-04-09 19:49:47,315 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt
2014-04-09 19:49:47,316 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2014-04-09 19:49:47,318 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.5.3
2014-04-09 19:49:47,318 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2014-04-09 19:49:47,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2014-04-09 19:49:47,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2014-04-09 19:49:47,323 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0031_m_000000_0 is done. And is in the process of commiting
2014-04-09 19:49:47,324 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2014-04-09 19:49:47,324 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0031_m_000000_0 is allowed to commit now
2014-04-09 19:49:47,325 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0031_m_000000_0' to file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2014-04-09 19:49:50,314 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/classes/test/data/nums.20.txt:0+51
2014-04-09 19:49:50,315 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0031_m_000000_0' done.
2014-04-09 19:49:50,320 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2014-04-09 19:49:50,328 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:50,332 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-04-09 19:49:50,332 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2014-04-09 19:49:50,335 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2014-04-09 19:49:50,335 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(205)) - using application jar: /home/brock/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.3/28aa68c14ec7f7fde8a1753ed3b6ac8e328e81dc/cascading-hadoop-2.5.3.jar
2014-04-09 19:49:50,337 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/brock/workspaces/cascading-compat/cascading.compatibility/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'