Class cascading.detail.EachEachPipeAssemblyPlatformTest

40

tests

0

failures

5.321s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 0.211s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 0.266s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 1.494s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 0.148s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 0.154s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.013s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.015s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 0.135s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 0.140s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.017s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 0.149s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 0.136s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 0.150s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.015s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.108s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.100s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.114s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 0.138s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 0.132s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 0.136s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 0.133s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.011s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 0.100s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.010s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 0.100s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.011s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 0.108s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 0.104s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 0.103s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.011s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.078s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.085s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.090s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 0.104s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 0.096s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 0.100s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 0.098s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 0.099s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 0.097s passed

Standard output

2013-11-20 14:38:29,976 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 14:38:30,002 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 14:38:30,002 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2013-11-20 14:38:30,039 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,056 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,066 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,076 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,083 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,090 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,097 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,097 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,103 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,109 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,115 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,115 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,116 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,118 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,119 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,120 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,126 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,127 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,133 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,141 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,149 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,158 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,174 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,174 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,182 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,189 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,189 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,190 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,190 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,191 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,194 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,195 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,198 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,199 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,202 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,205 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,209 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,212 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,218 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,221 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:30,388 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 14:38:30,733 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:30,735 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:30,750 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 89ECCD489A2148F494A1BADD740A45D6
2013-11-20 14:38:31,055 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 14:38:31,057 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:31,058 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:31,058 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-11-20 14:38:31,059 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:31,059 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:31,059 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:31,061 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:31,312 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 14:38:31,380 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-11-20 14:38:31,386 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:31,601 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local2092539708_0001
2013-11-20 14:38:31,633 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:31,638 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2092539708_0001_m_000000_0
2013-11-20 14:38:31,695 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 14:38:31,704 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3b8e80a6
2013-11-20 14:38:31,713 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:31,714 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@49c4a5ec
2013-11-20 14:38:31,721 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:31,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:31,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:31,792 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:31,792 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-11-20 14:38:31,806 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2092539708_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:31,811 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:31,811 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local2092539708_0001_m_000000_0 is allowed to commit now
2013-11-20 14:38:31,816 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2092539708_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:31,818 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:31,818 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2092539708_0001_m_000000_0' done.
2013-11-20 14:38:31,818 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2092539708_0001_m_000000_0
2013-11-20 14:38:31,818 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:31,830 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2013-11-20 14:38:31,854 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:31,878 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:31,881 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:31,903 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:31,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:31,926 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:31,926 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:31,926 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-11-20 14:38:31,927 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:31,927 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:31,927 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:31,927 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2013-11-20 14:38:31,944 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local967159701_0002
2013-11-20 14:38:32,048 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,048 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local967159701_0002_m_000000_0
2013-11-20 14:38:32,052 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@460ab1b4
2013-11-20 14:38:32,054 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,055 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2f3acc52
2013-11-20 14:38:32,057 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,076 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,076 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-11-20 14:38:32,079 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local967159701_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,081 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,082 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local967159701_0002_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,086 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local967159701_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-11-20 14:38:32,088 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,088 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local967159701_0002_m_000000_0' done.
2013-11-20 14:38:32,089 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local967159701_0002_m_000000_0
2013-11-20 14:38:32,089 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,097 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2013-11-20 14:38:32,120 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,145 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,147 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-11-20 14:38:32,165 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,166 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-11-20 14:38:32,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,189 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,190 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2013-11-20 14:38:32,206 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,268 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1843666528_0003
2013-11-20 14:38:32,273 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,273 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1843666528_0003_m_000000_0
2013-11-20 14:38:32,276 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2377ff35
2013-11-20 14:38:32,279 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,280 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@19852a81
2013-11-20 14:38:32,282 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,288 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,301 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,302 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-11-20 14:38:32,305 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1843666528_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,308 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,308 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1843666528_0003_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,313 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1843666528_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-11-20 14:38:32,315 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,315 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1843666528_0003_m_000000_0' done.
2013-11-20 14:38:32,316 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1843666528_0003_m_000000_0
2013-11-20 14:38:32,316 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,331 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2013-11-20 14:38:32,343 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,357 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,359 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-11-20 14:38:32,369 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,369 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,387 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,388 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,388 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-11-20 14:38:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,389 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,391 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2013-11-20 14:38:32,405 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,444 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1814166458_0004
2013-11-20 14:38:32,446 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,447 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1814166458_0004_m_000000_0
2013-11-20 14:38:32,448 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@66f9104a
2013-11-20 14:38:32,450 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,450 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@52257b34
2013-11-20 14:38:32,452 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,456 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,456 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,466 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,467 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-11-20 14:38:32,470 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1814166458_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,472 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,472 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1814166458_0004_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,476 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1814166458_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-11-20 14:38:32,477 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,477 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1814166458_0004_m_000000_0' done.
2013-11-20 14:38:32,478 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1814166458_0004_m_000000_0
2013-11-20 14:38:32,478 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,486 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2013-11-20 14:38:32,498 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,512 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,514 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-11-20 14:38:32,523 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,524 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,541 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,541 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,542 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-11-20 14:38:32,542 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,542 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,542 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,543 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:32,557 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,596 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1176897489_0005
2013-11-20 14:38:32,599 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,599 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1176897489_0005_m_000000_0
2013-11-20 14:38:32,602 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@201532fc
2013-11-20 14:38:32,604 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,604 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3589c12a
2013-11-20 14:38:32,606 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,610 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,610 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,619 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,620 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-11-20 14:38:32,623 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1176897489_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,625 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,625 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1176897489_0005_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,629 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1176897489_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:32,630 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,631 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1176897489_0005_m_000000_0' done.
2013-11-20 14:38:32,631 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1176897489_0005_m_000000_0
2013-11-20 14:38:32,631 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,638 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2013-11-20 14:38:32,649 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,661 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,663 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:32,672 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,672 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,694 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,695 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,695 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-11-20 14:38:32,696 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,696 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,696 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:32,713 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,747 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1283888009_0006
2013-11-20 14:38:32,750 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,750 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1283888009_0006_m_000000_0
2013-11-20 14:38:32,752 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6155035a
2013-11-20 14:38:32,754 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,754 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@72a60191
2013-11-20 14:38:32,755 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,759 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-11-20 14:38:32,772 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1283888009_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,774 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,775 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1283888009_0006_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,778 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1283888009_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:32,779 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,780 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1283888009_0006_m_000000_0' done.
2013-11-20 14:38:32,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1283888009_0006_m_000000_0
2013-11-20 14:38:32,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,789 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2013-11-20 14:38:32,799 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,811 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,813 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:32,822 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,823 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,830 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2013-11-20 14:38:32,840 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,841 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,857 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,857 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,858 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-11-20 14:38:32,858 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,858 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,858 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,859 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:32,870 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,905 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1194010509_0007
2013-11-20 14:38:32,908 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:32,909 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1194010509_0007_m_000000_0
2013-11-20 14:38:32,911 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@39849daf
2013-11-20 14:38:32,912 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:32,912 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@40944dbd
2013-11-20 14:38:32,914 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:32,918 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:32,918 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:32,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-11-20 14:38:32,930 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1194010509_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:32,932 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:32,933 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1194010509_0007_m_000000_0 is allowed to commit now
2013-11-20 14:38:32,936 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1194010509_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:32,937 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:32,938 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1194010509_0007_m_000000_0' done.
2013-11-20 14:38:32,938 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1194010509_0007_m_000000_0
2013-11-20 14:38:32,938 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:32,948 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2013-11-20 14:38:32,958 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,969 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:32,971 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:32,979 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:32,980 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:32,995 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:32,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:32,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-11-20 14:38:32,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:32,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:32,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:32,997 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:33,009 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local564953617_0008
2013-11-20 14:38:33,046 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,046 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local564953617_0008_m_000000_0
2013-11-20 14:38:33,049 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2398dc19
2013-11-20 14:38:33,051 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,051 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@30b5ac2c
2013-11-20 14:38:33,053 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,066 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,066 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-11-20 14:38:33,069 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local564953617_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:33,071 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:33,071 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local564953617_0008_m_000000_0 is allowed to commit now
2013-11-20 14:38:33,074 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local564953617_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:33,075 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:33,075 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local564953617_0008_m_000000_0' done.
2013-11-20 14:38:33,076 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local564953617_0008_m_000000_0
2013-11-20 14:38:33,076 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,087 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2013-11-20 14:38:33,108 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,119 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,121 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:33,130 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,130 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-11-20 14:38:33,147 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,148 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,148 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,152 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:33,163 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local919049281_0009
2013-11-20 14:38:33,190 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,191 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local919049281_0009_m_000000_0
2013-11-20 14:38:33,193 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@181f327e
2013-11-20 14:38:33,194 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,194 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3be7a755
2013-11-20 14:38:33,195 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,207 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,207 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-11-20 14:38:33,210 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local919049281_0009_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:33,212 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:33,212 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local919049281_0009_m_000000_0 is allowed to commit now
2013-11-20 14:38:33,215 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local919049281_0009_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:33,217 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:33,217 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local919049281_0009_m_000000_0' done.
2013-11-20 14:38:33,217 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local919049281_0009_m_000000_0
2013-11-20 14:38:33,218 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,234 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2013-11-20 14:38:33,245 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,256 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,257 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:33,266 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,267 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,281 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,282 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,282 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-11-20 14:38:33,282 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,282 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,283 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:33,295 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1106519071_0010
2013-11-20 14:38:33,323 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,323 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1106519071_0010_m_000000_0
2013-11-20 14:38:33,325 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4d2bbe6b
2013-11-20 14:38:33,327 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,327 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@45bb9533
2013-11-20 14:38:33,329 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,333 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,343 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,343 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-11-20 14:38:33,345 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,348 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,349 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,350 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,352 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1106519071_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,363 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:33,363 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:33,363 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:33,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:33,364 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:33,365 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2013-11-20 14:38:33,365 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:33,375 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,375 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,381 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2013-11-20 14:38:33,390 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,391 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,406 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,407 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,408 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-11-20 14:38:33,409 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,409 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,409 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:33,421 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,446 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1281492591_0011
2013-11-20 14:38:33,451 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,452 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1281492591_0011_m_000000_0
2013-11-20 14:38:33,454 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@758c3b7
2013-11-20 14:38:33,455 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,456 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@44ec366a
2013-11-20 14:38:33,457 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,461 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,461 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-11-20 14:38:33,469 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,470 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,471 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,472 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,481 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1281492591_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,490 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:33,493 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:33,494 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:33,494 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:33,495 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:33,495 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2013-11-20 14:38:33,496 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:33,506 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,506 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,522 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,523 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,524 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-11-20 14:38:33,525 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,525 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,525 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,527 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:33,538 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,563 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local406175548_0012
2013-11-20 14:38:33,567 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,567 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local406175548_0012_m_000000_0
2013-11-20 14:38:33,569 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@11652e61
2013-11-20 14:38:33,571 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,571 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@769fe666
2013-11-20 14:38:33,572 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,576 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,576 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,585 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-11-20 14:38:33,585 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,586 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,587 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,589 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,590 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local406175548_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:33,594 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:33,594 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:33,595 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:33,595 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:33,596 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:33,596 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2013-11-20 14:38:33,597 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:33,605 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,605 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,610 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2013-11-20 14:38:33,619 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,619 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,633 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,634 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,635 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-11-20 14:38:33,636 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,636 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,637 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,638 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:33,649 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,675 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local336593489_0013
2013-11-20 14:38:33,678 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,678 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local336593489_0013_m_000000_0
2013-11-20 14:38:33,681 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@67ee75a5
2013-11-20 14:38:33,683 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,684 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@271a2576
2013-11-20 14:38:33,686 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,691 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,691 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,700 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-11-20 14:38:33,703 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local336593489_0013_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:33,705 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:33,705 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local336593489_0013_m_000000_0 is allowed to commit now
2013-11-20 14:38:33,708 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local336593489_0013_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:33,710 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:33,710 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local336593489_0013_m_000000_0' done.
2013-11-20 14:38:33,710 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local336593489_0013_m_000000_0
2013-11-20 14:38:33,711 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2013-11-20 14:38:33,732 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,744 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,746 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:33,755 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,756 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,761 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2013-11-20 14:38:33,770 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,771 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,785 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,785 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,785 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-11-20 14:38:33,786 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,786 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,786 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,787 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2013-11-20 14:38:33,798 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,823 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1591096290_0014
2013-11-20 14:38:33,827 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,827 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1591096290_0014_m_000000_0
2013-11-20 14:38:33,831 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1fe91485
2013-11-20 14:38:33,832 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,832 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@247cb66a
2013-11-20 14:38:33,833 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,837 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,837 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-11-20 14:38:33,847 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1591096290_0014_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:33,849 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:33,849 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1591096290_0014_m_000000_0 is allowed to commit now
2013-11-20 14:38:33,851 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1591096290_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-11-20 14:38:33,853 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:33,853 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1591096290_0014_m_000000_0' done.
2013-11-20 14:38:33,854 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1591096290_0014_m_000000_0
2013-11-20 14:38:33,854 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:33,868 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2013-11-20 14:38:33,878 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,892 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,894 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-11-20 14:38:33,903 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:33,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:33,917 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:33,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-11-20 14:38:33,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:33,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:33,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:33,920 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2013-11-20 14:38:33,933 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:33,964 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local277069148_0015
2013-11-20 14:38:33,967 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:33,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local277069148_0015_m_000000_0
2013-11-20 14:38:33,971 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19d1b44b
2013-11-20 14:38:33,973 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:33,973 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7b9a29
2013-11-20 14:38:33,975 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:33,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:33,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:33,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:33,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-11-20 14:38:33,990 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local277069148_0015_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:33,992 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:33,992 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local277069148_0015_m_000000_0 is allowed to commit now
2013-11-20 14:38:33,995 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local277069148_0015_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-11-20 14:38:33,996 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:33,996 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local277069148_0015_m_000000_0' done.
2013-11-20 14:38:33,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local277069148_0015_m_000000_0
2013-11-20 14:38:33,997 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,008 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2013-11-20 14:38:34,018 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,030 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,032 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-11-20 14:38:34,041 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,041 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,054 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,055 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,055 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-11-20 14:38:34,055 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,056 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,056 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,056 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2013-11-20 14:38:34,068 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,097 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local103102068_0016
2013-11-20 14:38:34,100 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,100 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local103102068_0016_m_000000_0
2013-11-20 14:38:34,103 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@a868c6d
2013-11-20 14:38:34,107 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,107 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@65cc892e
2013-11-20 14:38:34,108 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-11-20 14:38:34,124 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local103102068_0016_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,126 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,126 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local103102068_0016_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,129 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local103102068_0016_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-11-20 14:38:34,132 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,132 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local103102068_0016_m_000000_0' done.
2013-11-20 14:38:34,132 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local103102068_0016_m_000000_0
2013-11-20 14:38:34,132 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,142 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2013-11-20 14:38:34,152 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,163 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,164 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-11-20 14:38:34,173 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,174 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-11-20 14:38:34,187 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,188 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,188 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:34,199 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,235 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1095259680_0017
2013-11-20 14:38:34,238 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,238 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1095259680_0017_m_000000_0
2013-11-20 14:38:34,241 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@43665a0d
2013-11-20 14:38:34,243 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,243 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@121a2cc7
2013-11-20 14:38:34,244 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,255 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,255 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-11-20 14:38:34,258 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1095259680_0017_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,260 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,260 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1095259680_0017_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,263 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1095259680_0017_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:34,265 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,265 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1095259680_0017_m_000000_0' done.
2013-11-20 14:38:34,265 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1095259680_0017_m_000000_0
2013-11-20 14:38:34,266 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,279 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2013-11-20 14:38:34,288 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,299 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,300 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:34,308 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,309 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,320 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,320 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,321 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-11-20 14:38:34,321 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,321 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,321 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,322 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:34,332 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1279314347_0018
2013-11-20 14:38:34,358 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,359 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1279314347_0018_m_000000_0
2013-11-20 14:38:34,360 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@da4a1c9
2013-11-20 14:38:34,361 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,361 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@24164d75
2013-11-20 14:38:34,362 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,365 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,365 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,373 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,373 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-11-20 14:38:34,376 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1279314347_0018_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,378 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,378 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1279314347_0018_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,380 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1279314347_0018_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:34,382 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,382 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1279314347_0018_m_000000_0' done.
2013-11-20 14:38:34,382 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1279314347_0018_m_000000_0
2013-11-20 14:38:34,382 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,389 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2013-11-20 14:38:34,398 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,407 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,408 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:34,415 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,416 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,419 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2013-11-20 14:38:34,427 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,427 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,437 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,438 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,438 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-11-20 14:38:34,438 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,438 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,438 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,439 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:34,448 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,470 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1367901500_0019
2013-11-20 14:38:34,473 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,473 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1367901500_0019_m_000000_0
2013-11-20 14:38:34,474 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@44585f2a
2013-11-20 14:38:34,476 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,476 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@8071a97
2013-11-20 14:38:34,477 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,485 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,485 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-11-20 14:38:34,488 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1367901500_0019_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,489 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,489 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1367901500_0019_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,492 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1367901500_0019_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:34,494 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,494 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1367901500_0019_m_000000_0' done.
2013-11-20 14:38:34,494 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1367901500_0019_m_000000_0
2013-11-20 14:38:34,494 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,503 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2013-11-20 14:38:34,511 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,521 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,523 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:34,530 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,530 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-11-20 14:38:34,541 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,541 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,541 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,542 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:34,550 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,575 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local305074868_0020
2013-11-20 14:38:34,577 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,577 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local305074868_0020_m_000000_0
2013-11-20 14:38:34,579 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@207c15c0
2013-11-20 14:38:34,580 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,580 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@15136019
2013-11-20 14:38:34,581 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,584 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-11-20 14:38:34,593 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local305074868_0020_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,594 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,594 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local305074868_0020_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,597 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local305074868_0020_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:34,598 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,598 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local305074868_0020_m_000000_0' done.
2013-11-20 14:38:34,598 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local305074868_0020_m_000000_0
2013-11-20 14:38:34,598 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,607 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2013-11-20 14:38:34,616 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,625 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,627 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:34,634 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,634 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,645 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,645 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,645 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-11-20 14:38:34,646 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,646 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,646 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,646 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-11-20 14:38:34,657 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,681 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local347799832_0021
2013-11-20 14:38:34,683 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,684 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local347799832_0021_m_000000_0
2013-11-20 14:38:34,685 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@17feafba
2013-11-20 14:38:34,686 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,686 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5655d1b4
2013-11-20 14:38:34,687 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,696 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,696 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-11-20 14:38:34,697 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,698 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,698 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,699 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,700 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local347799832_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,702 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:34,702 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:34,703 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:34,703 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-11-20 14:38:34,703 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:34,703 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] shutting down job executor
2013-11-20 14:38:34,704 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] shutdown complete
2013-11-20 14:38:34,704 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2013-11-20 14:38:34,704 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2013-11-20 14:38:34,712 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,716 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2013-11-20 14:38:34,723 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,724 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,733 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,734 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-11-20 14:38:34,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,735 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,736 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:34,745 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,765 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1724766741_0022
2013-11-20 14:38:34,768 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,768 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1724766741_0022_m_000000_0
2013-11-20 14:38:34,771 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7bc221b2
2013-11-20 14:38:34,772 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,773 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5da0ff10
2013-11-20 14:38:34,774 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-11-20 14:38:34,785 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,786 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,793 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,796 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,796 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1724766741_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,803 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:34,803 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:34,803 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:34,804 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:34,804 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:34,805 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2013-11-20 14:38:34,805 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:34,814 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,814 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,823 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,824 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,824 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-11-20 14:38:34,824 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,824 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,825 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,825 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:34,837 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,858 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1333194999_0023
2013-11-20 14:38:34,861 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,861 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1333194999_0023_m_000000_0
2013-11-20 14:38:34,863 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@51d9d7ab
2013-11-20 14:38:34,864 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,865 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7440d1b0
2013-11-20 14:38:34,866 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-11-20 14:38:34,876 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,877 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,878 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,879 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,880 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1333194999_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:34,889 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-11-20 14:38:34,889 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-11-20 14:38:34,890 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-11-20 14:38:34,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:34,890 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-11-20 14:38:34,891 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2013-11-20 14:38:34,891 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:34,899 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:34,899 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:34,908 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:34,910 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,910 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-11-20 14:38:34,910 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:34,911 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:34,911 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:34,911 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:34,919 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,941 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local742193039_0024
2013-11-20 14:38:34,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:34,945 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local742193039_0024_m_000000_0
2013-11-20 14:38:34,947 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7185d3cc
2013-11-20 14:38:34,948 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:34,948 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@74b90ff7
2013-11-20 14:38:34,949 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:34,951 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:34,951 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:34,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:34,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-11-20 14:38:34,960 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local742193039_0024_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:34,962 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:34,962 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local742193039_0024_m_000000_0 is allowed to commit now
2013-11-20 14:38:34,964 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local742193039_0024_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:34,965 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:34,965 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local742193039_0024_m_000000_0' done.
2013-11-20 14:38:34,965 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local742193039_0024_m_000000_0
2013-11-20 14:38:34,966 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:34,974 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2013-11-20 14:38:34,982 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,991 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:34,992 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:35,000 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,000 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,003 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2013-11-20 14:38:35,010 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,011 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,021 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,021 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-11-20 14:38:35,021 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,021 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,022 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,023 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:35,030 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,053 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local385985683_0025
2013-11-20 14:38:35,055 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,056 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local385985683_0025_m_000000_0
2013-11-20 14:38:35,057 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3da5f0f3
2013-11-20 14:38:35,058 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,058 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@794f8b9a
2013-11-20 14:38:35,059 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,061 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,062 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-11-20 14:38:35,069 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local385985683_0025_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,071 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,071 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local385985683_0025_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,074 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local385985683_0025_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:35,075 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,075 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local385985683_0025_m_000000_0' done.
2013-11-20 14:38:35,075 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local385985683_0025_m_000000_0
2013-11-20 14:38:35,076 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,085 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2013-11-20 14:38:35,093 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,103 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,104 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:35,111 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,112 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,115 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2013-11-20 14:38:35,123 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,123 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,131 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-11-20 14:38:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,132 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,133 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:35,141 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,162 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local444433886_0026
2013-11-20 14:38:35,166 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,166 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local444433886_0026_m_000000_0
2013-11-20 14:38:35,168 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@52a9fd96
2013-11-20 14:38:35,169 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,169 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5e8b957
2013-11-20 14:38:35,170 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,172 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,172 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,179 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-11-20 14:38:35,181 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local444433886_0026_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,183 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,183 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local444433886_0026_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,185 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local444433886_0026_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:35,187 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,187 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local444433886_0026_m_000000_0' done.
2013-11-20 14:38:35,187 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local444433886_0026_m_000000_0
2013-11-20 14:38:35,188 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,196 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2013-11-20 14:38:35,204 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,214 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:35,223 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,223 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,231 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,232 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,232 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-11-20 14:38:35,232 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,232 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,232 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,233 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2013-11-20 14:38:35,240 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local105778576_0027
2013-11-20 14:38:35,263 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,263 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local105778576_0027_m_000000_0
2013-11-20 14:38:35,264 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@21c33b55
2013-11-20 14:38:35,265 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,265 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@35cfb8d3
2013-11-20 14:38:35,266 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,269 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,269 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,274 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-11-20 14:38:35,277 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local105778576_0027_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,279 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,279 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local105778576_0027_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,281 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local105778576_0027_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-11-20 14:38:35,282 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,283 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local105778576_0027_m_000000_0' done.
2013-11-20 14:38:35,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local105778576_0027_m_000000_0
2013-11-20 14:38:35,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,293 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2013-11-20 14:38:35,301 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,311 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,312 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-11-20 14:38:35,319 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,319 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,327 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,328 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,328 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-11-20 14:38:35,328 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,328 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,328 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,329 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2013-11-20 14:38:35,341 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,363 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1902294165_0028
2013-11-20 14:38:35,368 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,368 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1902294165_0028_m_000000_0
2013-11-20 14:38:35,370 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@483c4c33
2013-11-20 14:38:35,371 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,371 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@350204ce
2013-11-20 14:38:35,372 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,380 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,381 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-11-20 14:38:35,383 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1902294165_0028_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,385 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,385 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1902294165_0028_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,387 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1902294165_0028_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-11-20 14:38:35,388 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,388 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1902294165_0028_m_000000_0' done.
2013-11-20 14:38:35,388 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1902294165_0028_m_000000_0
2013-11-20 14:38:35,389 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,397 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2013-11-20 14:38:35,405 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,414 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,415 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-11-20 14:38:35,426 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,427 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-11-20 14:38:35,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,437 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:35,445 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,464 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1634214789_0029
2013-11-20 14:38:35,467 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,467 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1634214789_0029_m_000000_0
2013-11-20 14:38:35,468 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4dba4b54
2013-11-20 14:38:35,469 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,469 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@62ad4bb0
2013-11-20 14:38:35,470 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-11-20 14:38:35,482 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1634214789_0029_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,484 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,484 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1634214789_0029_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,486 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1634214789_0029_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:35,487 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,487 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1634214789_0029_m_000000_0' done.
2013-11-20 14:38:35,487 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1634214789_0029_m_000000_0
2013-11-20 14:38:35,488 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,497 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2013-11-20 14:38:35,505 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,513 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,514 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:35,521 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,522 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,529 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,530 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,530 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-11-20 14:38:35,531 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,531 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,531 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,532 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:35,540 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local57040881_0030
2013-11-20 14:38:35,563 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,563 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local57040881_0030_m_000000_0
2013-11-20 14:38:35,565 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2aae3614
2013-11-20 14:38:35,566 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,566 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2ff7ac92
2013-11-20 14:38:35,567 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,574 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,575 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-11-20 14:38:35,577 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local57040881_0030_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,578 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,579 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local57040881_0030_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,581 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local57040881_0030_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:35,582 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,582 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local57040881_0030_m_000000_0' done.
2013-11-20 14:38:35,582 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local57040881_0030_m_000000_0
2013-11-20 14:38:35,582 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2013-11-20 14:38:35,602 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,611 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,613 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:35,620 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,621 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,629 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-11-20 14:38:35,629 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,629 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-11-20 14:38:35,629 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-11-20 14:38:35,630 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-11-20 14:38:35,630 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-11-20 14:38:35,630 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:35,639 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local1353639561_0031
2013-11-20 14:38:35,661 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:35,661 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1353639561_0031_m_000000_0
2013-11-20 14:38:35,663 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@31395750
2013-11-20 14:38:35,664 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:35,664 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@d121b88
2013-11-20 14:38:35,665 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:35,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:35,668 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:35,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:35,673 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-11-20 14:38:35,676 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1353639561_0031_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:35,677 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:38:35,677 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1353639561_0031_m_000000_0 is allowed to commit now
2013-11-20 14:38:35,679 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1353639561_0031_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:35,681 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:35,681 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1353639561_0031_m_000000_0' done.
2013-11-20 14:38:35,681 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1353639561_0031_m_000000_0
2013-11-20 14:38:35,681 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:35,691 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2013-11-20 14:38:35,698 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,708 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:35,710 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:35,718 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:35,719 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:35,722 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'