Class cascading.detail.EachEachPipeAssemblyPlatformTest

40

tests

0

failures

0

ignored

1m17.23s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 3.110s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 3.119s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 3.466s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 3.076s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 3.073s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.007s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.006s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 3.056s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 3.067s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.007s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 3.075s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 3.061s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 3.066s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.007s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.052s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.051s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.052s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 3.054s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 3.051s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 3.052s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 3.052s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.005s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 3.046s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.006s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 3.053s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.006s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 3.049s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 3.043s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 3.045s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.048s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.033s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.034s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 3.056s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 3.051s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 3.047s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 3.042s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 3.044s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.005s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 3.049s passed

Standard output

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'