2015-02-10 17:24:58,003 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 17:24:58,051 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 17:24:58,052 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2015-02-10 17:24:58,140 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,158 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,168 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,177 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,184 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,191 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,197 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,198 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,203 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,208 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,213 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,214 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,215 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,217 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,217 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,218 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,223 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,223 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,229 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,237 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,245 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,252 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,260 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,260 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,264 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,268 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,269 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,269 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,270 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,270 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,274 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,275 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,278 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,279 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,283 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,286 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,290 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,293 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,297 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,300 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 17:24:58,624 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 17:24:59,033 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:24:59,035 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:24:59,049 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 0A6C7E404E764A70B37ED98BE5C5741D
2015-02-10 17:24:59,263 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 17:24:59,266 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:24:59,267 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:24:59,268 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-02-10 17:24:59,268 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:24:59,268 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:24:59,268 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:24:59,271 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-02-10 17:24:59,318 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 17:24:59,388 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 17:24:59,391 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:24:59,619 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local998734381_0001
2015-02-10 17:24:59,620 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:24:59,653 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:24:59,657 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local998734381_0001_m_000000_0
2015-02-10 17:24:59,717 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 17:24:59,725 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3e5b38d7
2015-02-10 17:24:59,734 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:24:59,735 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@520e7d53
2015-02-10 17:24:59,743 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:24:59,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:24:59,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:24:59,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:24:59,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-02-10 17:24:59,839 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local998734381_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:24:59,844 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:24:59,844 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local998734381_0001_m_000000_0 is allowed to commit now
2015-02-10 17:24:59,849 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local998734381_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-02-10 17:24:59,852 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:24:59,852 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local998734381_0001_m_000000_0' done.
2015-02-10 17:24:59,852 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local998734381_0001_m_000000_0
2015-02-10 17:24:59,852 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:24:59,869 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-02-10 17:24:59,897 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:24:59,927 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:24:59,929 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-02-10 17:24:59,955 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:24:59,955 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:24:59,982 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:24:59,983 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:24:59,983 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-02-10 17:24:59,984 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:24:59,984 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:24:59,985 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:24:59,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-02-10 17:25:00,003 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,109 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1122554015_0002
2015-02-10 17:25:00,109 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:00,112 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:00,112 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1122554015_0002_m_000000_0
2015-02-10 17:25:00,115 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2d388e5e
2015-02-10 17:25:00,118 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:00,118 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@25861086
2015-02-10 17:25:00,121 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:00,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:00,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:00,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-02-10 17:25:00,148 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1122554015_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:00,151 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:00,151 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1122554015_0002_m_000000_0 is allowed to commit now
2015-02-10 17:25:00,156 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1122554015_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-02-10 17:25:00,158 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:00,158 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1122554015_0002_m_000000_0' done.
2015-02-10 17:25:00,158 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1122554015_0002_m_000000_0
2015-02-10 17:25:00,159 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:00,172 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-02-10 17:25:00,196 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,223 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,225 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-02-10 17:25:00,247 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,248 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:00,275 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:00,276 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,277 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-02-10 17:25:00,277 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:00,277 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:00,277 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:00,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-02-10 17:25:00,296 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,355 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1677486429_0003
2015-02-10 17:25:00,355 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:00,359 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:00,359 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1677486429_0003_m_000000_0
2015-02-10 17:25:00,362 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7284aa02
2015-02-10 17:25:00,365 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:00,365 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2d9f90e3
2015-02-10 17:25:00,367 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:00,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:00,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:00,388 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,389 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-02-10 17:25:00,393 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1677486429_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:00,396 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:00,396 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1677486429_0003_m_000000_0 is allowed to commit now
2015-02-10 17:25:00,401 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1677486429_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-02-10 17:25:00,403 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:00,404 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1677486429_0003_m_000000_0' done.
2015-02-10 17:25:00,404 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1677486429_0003_m_000000_0
2015-02-10 17:25:00,405 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:00,418 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-02-10 17:25:00,433 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,450 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,452 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-02-10 17:25:00,466 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,466 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:00,494 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:00,494 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,494 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-02-10 17:25:00,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:00,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:00,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:00,497 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-02-10 17:25:00,513 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1796462962_0004
2015-02-10 17:25:00,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:00,559 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:00,559 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1796462962_0004_m_000000_0
2015-02-10 17:25:00,561 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@69b0de2e
2015-02-10 17:25:00,563 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:00,564 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@399197b
2015-02-10 17:25:00,566 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:00,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:00,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:00,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-02-10 17:25:00,588 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1796462962_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:00,590 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:00,590 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1796462962_0004_m_000000_0 is allowed to commit now
2015-02-10 17:25:00,595 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1796462962_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-02-10 17:25:00,597 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:00,597 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1796462962_0004_m_000000_0' done.
2015-02-10 17:25:00,597 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1796462962_0004_m_000000_0
2015-02-10 17:25:00,597 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:00,609 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-02-10 17:25:00,623 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,637 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,639 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-02-10 17:25:00,650 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,650 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:00,669 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:00,670 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,670 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-02-10 17:25:00,670 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:00,670 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:00,670 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:00,672 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-02-10 17:25:00,689 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,732 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local935261391_0005
2015-02-10 17:25:00,732 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:00,734 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:00,735 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local935261391_0005_m_000000_0
2015-02-10 17:25:00,736 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5608a6fc
2015-02-10 17:25:00,738 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:00,738 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@21b38cdc
2015-02-10 17:25:00,740 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:00,744 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:00,745 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:00,754 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-02-10 17:25:00,758 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local935261391_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:00,760 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:00,762 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local935261391_0005_m_000000_0 is allowed to commit now
2015-02-10 17:25:00,766 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local935261391_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-02-10 17:25:00,767 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:00,768 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local935261391_0005_m_000000_0' done.
2015-02-10 17:25:00,768 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local935261391_0005_m_000000_0
2015-02-10 17:25:00,768 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:00,775 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-02-10 17:25:00,787 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,799 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,801 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-02-10 17:25:00,811 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,812 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:00,831 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:00,831 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,832 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-02-10 17:25:00,832 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:00,832 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:00,832 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:00,833 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-02-10 17:25:00,849 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local902403567_0006
2015-02-10 17:25:00,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:00,889 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:00,889 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local902403567_0006_m_000000_0
2015-02-10 17:25:00,891 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@f292738
2015-02-10 17:25:00,892 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:00,892 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@722e242b
2015-02-10 17:25:00,894 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:00,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:00,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:00,911 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:00,911 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-02-10 17:25:00,914 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local902403567_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:00,917 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:00,917 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local902403567_0006_m_000000_0 is allowed to commit now
2015-02-10 17:25:00,921 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local902403567_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-02-10 17:25:00,922 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:00,923 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local902403567_0006_m_000000_0' done.
2015-02-10 17:25:00,923 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local902403567_0006_m_000000_0
2015-02-10 17:25:00,923 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:00,928 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-02-10 17:25:00,940 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,953 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:00,954 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-02-10 17:25:00,964 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,965 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:00,973 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-02-10 17:25:00,982 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:00,983 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,003 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,004 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,004 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-02-10 17:25:01,004 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,004 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,004 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,005 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-02-10 17:25:01,018 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,051 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local491134103_0007
2015-02-10 17:25:01,051 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,055 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,055 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local491134103_0007_m_000000_0
2015-02-10 17:25:01,057 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@899ff91
2015-02-10 17:25:01,059 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,060 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3739491b
2015-02-10 17:25:01,062 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-02-10 17:25:01,082 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local491134103_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:01,084 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:01,084 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local491134103_0007_m_000000_0 is allowed to commit now
2015-02-10 17:25:01,087 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local491134103_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-02-10 17:25:01,089 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:01,089 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local491134103_0007_m_000000_0' done.
2015-02-10 17:25:01,090 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local491134103_0007_m_000000_0
2015-02-10 17:25:01,090 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,108 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-02-10 17:25:01,120 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,132 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,134 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-02-10 17:25:01,143 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,144 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,163 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,163 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,163 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-02-10 17:25:01,164 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,164 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,164 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-02-10 17:25:01,178 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,211 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local458655724_0008
2015-02-10 17:25:01,212 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,216 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,216 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local458655724_0008_m_000000_0
2015-02-10 17:25:01,218 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4e2d8ecc
2015-02-10 17:25:01,219 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,219 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@19176e5f
2015-02-10 17:25:01,221 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-02-10 17:25:01,237 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local458655724_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:01,239 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:01,239 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local458655724_0008_m_000000_0 is allowed to commit now
2015-02-10 17:25:01,243 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local458655724_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-02-10 17:25:01,244 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:01,244 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local458655724_0008_m_000000_0' done.
2015-02-10 17:25:01,245 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local458655724_0008_m_000000_0
2015-02-10 17:25:01,245 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,259 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-02-10 17:25:01,270 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,282 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,291 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-02-10 17:25:01,306 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,306 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,324 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,325 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,325 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-02-10 17:25:01,325 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,325 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,325 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,326 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 17:25:01,338 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,365 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local819753903_0009
2015-02-10 17:25:01,365 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,368 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,368 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local819753903_0009_m_000000_0
2015-02-10 17:25:01,370 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5114ef62
2015-02-10 17:25:01,371 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,371 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1241647f
2015-02-10 17:25:01,373 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,386 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-02-10 17:25:01,389 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local819753903_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:01,391 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:01,391 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local819753903_0009_m_000000_0 is allowed to commit now
2015-02-10 17:25:01,394 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local819753903_0009_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 17:25:01,396 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:01,396 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local819753903_0009_m_000000_0' done.
2015-02-10 17:25:01,396 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local819753903_0009_m_000000_0
2015-02-10 17:25:01,397 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,409 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-02-10 17:25:01,419 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,430 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 17:25:01,440 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,441 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,458 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,458 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,458 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-02-10 17:25:01,460 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,460 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,460 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,463 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-02-10 17:25:01,476 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,507 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1498958203_0010
2015-02-10 17:25:01,507 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,510 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,510 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1498958203_0010_m_000000_0
2015-02-10 17:25:01,512 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1adbbe8b
2015-02-10 17:25:01,514 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,515 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1ae0e7d
2015-02-10 17:25:01,517 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,531 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,531 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-02-10 17:25:01,533 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,544 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,546 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,547 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,548 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1498958203_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,551 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local1498958203_0010 state at FAILED
2015-02-10 17:25:01,551 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:01,553 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:01,553 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:01,553 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:01,554 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-02-10 17:25:01,554 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:01,555 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-02-10 17:25:01,555 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-02-10 17:25:01,564 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,565 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,571 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-02-10 17:25:01,579 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,580 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,596 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,597 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,598 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-02-10 17:25:01,599 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,599 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,600 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,601 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-02-10 17:25:01,614 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,642 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local360302891_0011
2015-02-10 17:25:01,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,649 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,649 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local360302891_0011_m_000000_0
2015-02-10 17:25:01,651 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6e8af0b0
2015-02-10 17:25:01,652 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,653 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@29d6399b
2015-02-10 17:25:01,654 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-02-10 17:25:01,668 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,669 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,670 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,671 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,673 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local360302891_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,675 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local360302891_0011 state at FAILED
2015-02-10 17:25:01,675 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:01,675 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:01,676 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:01,676 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:01,678 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-02-10 17:25:01,678 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:01,678 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-02-10 17:25:01,679 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-02-10 17:25:01,689 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,690 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,710 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,711 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,712 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-02-10 17:25:01,712 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,713 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,713 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-02-10 17:25:01,727 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local336975507_0012
2015-02-10 17:25:01,756 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,760 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,760 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local336975507_0012_m_000000_0
2015-02-10 17:25:01,762 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4eb55c7f
2015-02-10 17:25:01,764 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,764 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@eaa4c7c
2015-02-10 17:25:01,765 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,780 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-02-10 17:25:01,781 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,782 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,783 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,784 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,785 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local336975507_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:01,787 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local336975507_0012 state at FAILED
2015-02-10 17:25:01,787 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:01,788 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:01,788 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:01,788 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:01,789 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-02-10 17:25:01,789 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:01,789 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] shutting down job executor
2015-02-10 17:25:01,790 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] shutdown complete
2015-02-10 17:25:01,790 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-02-10 17:25:01,791 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-02-10 17:25:01,800 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,800 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,806 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-02-10 17:25:01,816 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,817 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,834 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,834 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,835 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-02-10 17:25:01,835 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,835 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,835 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,836 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-02-10 17:25:01,848 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,874 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1120199026_0013
2015-02-10 17:25:01,876 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:01,879 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:01,879 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1120199026_0013_m_000000_0
2015-02-10 17:25:01,881 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7be84195
2015-02-10 17:25:01,883 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:01,883 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5eb8f6d
2015-02-10 17:25:01,885 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:01,889 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:01,889 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:01,898 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,898 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-02-10 17:25:01,901 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1120199026_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:01,903 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:01,903 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1120199026_0013_m_000000_0 is allowed to commit now
2015-02-10 17:25:01,906 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1120199026_0013_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-02-10 17:25:01,908 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:01,908 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1120199026_0013_m_000000_0' done.
2015-02-10 17:25:01,909 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1120199026_0013_m_000000_0
2015-02-10 17:25:01,909 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:01,919 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-02-10 17:25:01,929 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,940 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:01,941 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-02-10 17:25:01,951 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,951 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,956 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-02-10 17:25:01,965 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:01,965 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:01,987 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:01,989 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:01,991 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-02-10 17:25:01,992 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:01,993 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:01,993 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:01,996 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-02-10 17:25:02,007 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,036 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local994675884_0014
2015-02-10 17:25:02,038 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,039 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,040 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local994675884_0014_m_000000_0
2015-02-10 17:25:02,041 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2cdf88d2
2015-02-10 17:25:02,043 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,043 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1fe5052b
2015-02-10 17:25:02,044 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,057 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-02-10 17:25:02,060 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local994675884_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,062 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,062 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local994675884_0014_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,065 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local994675884_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-02-10 17:25:02,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,067 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local994675884_0014_m_000000_0' done.
2015-02-10 17:25:02,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local994675884_0014_m_000000_0
2015-02-10 17:25:02,067 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,082 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-02-10 17:25:02,091 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,103 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,104 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-02-10 17:25:02,113 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,114 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,127 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,128 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,128 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-02-10 17:25:02,128 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,129 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,129 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,131 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-02-10 17:25:02,141 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local581043093_0015
2015-02-10 17:25:02,167 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,171 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,171 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local581043093_0015_m_000000_0
2015-02-10 17:25:02,173 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@76ea7776
2015-02-10 17:25:02,174 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,175 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2fe6707
2015-02-10 17:25:02,176 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,180 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,180 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-02-10 17:25:02,193 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local581043093_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,195 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,195 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local581043093_0015_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,198 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local581043093_0015_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-02-10 17:25:02,200 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,200 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local581043093_0015_m_000000_0' done.
2015-02-10 17:25:02,200 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local581043093_0015_m_000000_0
2015-02-10 17:25:02,200 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,210 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-02-10 17:25:02,220 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,230 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,231 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-02-10 17:25:02,240 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,240 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,253 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,253 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,253 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-02-10 17:25:02,253 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,253 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,254 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,254 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-02-10 17:25:02,264 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,288 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1853822252_0016
2015-02-10 17:25:02,290 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,292 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,292 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1853822252_0016_m_000000_0
2015-02-10 17:25:02,294 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@e3f6d
2015-02-10 17:25:02,296 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,297 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@29086036
2015-02-10 17:25:02,298 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-02-10 17:25:02,313 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1853822252_0016_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,315 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,315 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1853822252_0016_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,317 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1853822252_0016_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-02-10 17:25:02,319 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,320 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1853822252_0016_m_000000_0' done.
2015-02-10 17:25:02,320 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1853822252_0016_m_000000_0
2015-02-10 17:25:02,320 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,333 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-02-10 17:25:02,342 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,352 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,353 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-02-10 17:25:02,361 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,362 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-02-10 17:25:02,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,374 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,375 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,375 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-02-10 17:25:02,386 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,412 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1425461813_0017
2015-02-10 17:25:02,412 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,414 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,414 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1425461813_0017_m_000000_0
2015-02-10 17:25:02,416 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19a40cfc
2015-02-10 17:25:02,417 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,417 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4bbf8a41
2015-02-10 17:25:02,419 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,422 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,422 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,431 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,431 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-02-10 17:25:02,434 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1425461813_0017_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,436 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,436 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1425461813_0017_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,439 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1425461813_0017_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-02-10 17:25:02,440 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,440 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1425461813_0017_m_000000_0' done.
2015-02-10 17:25:02,441 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1425461813_0017_m_000000_0
2015-02-10 17:25:02,441 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,455 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-02-10 17:25:02,464 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,474 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,475 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-02-10 17:25:02,483 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,484 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,495 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-02-10 17:25:02,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,496 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,497 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-02-10 17:25:02,506 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,531 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local902221779_0018
2015-02-10 17:25:02,531 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,533 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,533 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local902221779_0018_m_000000_0
2015-02-10 17:25:02,535 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@360c7f06
2015-02-10 17:25:02,536 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,536 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2aa96fd2
2015-02-10 17:25:02,537 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-02-10 17:25:02,551 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local902221779_0018_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,552 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,553 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local902221779_0018_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,555 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local902221779_0018_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-02-10 17:25:02,557 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,558 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local902221779_0018_m_000000_0' done.
2015-02-10 17:25:02,558 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local902221779_0018_m_000000_0
2015-02-10 17:25:02,558 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,563 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-02-10 17:25:02,572 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,582 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,583 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-02-10 17:25:02,591 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,592 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,596 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-02-10 17:25:02,604 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,604 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,625 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,626 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,626 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-02-10 17:25:02,627 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,628 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,628 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,630 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-02-10 17:25:02,638 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,661 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1371156170_0019
2015-02-10 17:25:02,661 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,664 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,664 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1371156170_0019_m_000000_0
2015-02-10 17:25:02,666 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6665e41
2015-02-10 17:25:02,667 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,667 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7f29b922
2015-02-10 17:25:02,669 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,680 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-02-10 17:25:02,683 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1371156170_0019_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,684 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,684 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1371156170_0019_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,687 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1371156170_0019_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-02-10 17:25:02,688 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,689 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1371156170_0019_m_000000_0' done.
2015-02-10 17:25:02,689 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1371156170_0019_m_000000_0
2015-02-10 17:25:02,689 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,694 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-02-10 17:25:02,703 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,713 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,714 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-02-10 17:25:02,722 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,723 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,735 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-02-10 17:25:02,744 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,768 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local731128625_0020
2015-02-10 17:25:02,768 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,770 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,771 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local731128625_0020_m_000000_0
2015-02-10 17:25:02,772 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1a3a2a52
2015-02-10 17:25:02,773 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,773 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@25630eb6
2015-02-10 17:25:02,775 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,778 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,785 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,785 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-02-10 17:25:02,788 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local731128625_0020_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:02,790 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:02,790 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local731128625_0020_m_000000_0 is allowed to commit now
2015-02-10 17:25:02,793 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local731128625_0020_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-02-10 17:25:02,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:02,796 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local731128625_0020_m_000000_0' done.
2015-02-10 17:25:02,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local731128625_0020_m_000000_0
2015-02-10 17:25:02,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,800 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-02-10 17:25:02,809 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,819 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,820 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-02-10 17:25:02,828 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,828 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,838 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,839 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,839 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-02-10 17:25:02,839 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,839 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,839 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,840 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-02-10 17:25:02,849 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,871 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local607407828_0021
2015-02-10 17:25:02,871 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,874 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,874 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local607407828_0021_m_000000_0
2015-02-10 17:25:02,875 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@399b08cc
2015-02-10 17:25:02,876 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,876 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@106258e1
2015-02-10 17:25:02,877 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-02-10 17:25:02,888 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,888 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,889 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,890 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,891 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local607407828_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,892 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local607407828_0021 state at FAILED
2015-02-10 17:25:02,893 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:02,893 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:02,893 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:02,893 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:02,894 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-02-10 17:25:02,894 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:02,895 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-02-10 17:25:02,895 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-02-10 17:25:02,903 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,904 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,907 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-02-10 17:25:02,915 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:02,916 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:02,926 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:02,926 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,926 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-02-10 17:25:02,926 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:02,927 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:02,927 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:02,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-02-10 17:25:02,936 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:02,958 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1510496101_0022
2015-02-10 17:25:02,958 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:02,960 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:02,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1510496101_0022_m_000000_0
2015-02-10 17:25:02,963 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4be0bf98
2015-02-10 17:25:02,964 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:02,964 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@171ccb0
2015-02-10 17:25:02,966 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:02,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:02,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:02,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:02,977 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-02-10 17:25:02,977 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,978 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,979 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,980 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:02,981 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1510496101_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:02,989 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local1510496101_0022 state at FAILED
2015-02-10 17:25:02,989 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:02,989 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:02,989 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:02,990 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:02,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-02-10 17:25:02,990 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:02,990 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] shutting down job executor
2015-02-10 17:25:02,991 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] shutdown complete
2015-02-10 17:25:02,991 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-02-10 17:25:02,991 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-02-10 17:25:03,001 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,002 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,015 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,015 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,016 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-02-10 17:25:03,016 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,016 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,016 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,017 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-02-10 17:25:03,029 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,059 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local373800336_0023
2015-02-10 17:25:03,060 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,107 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,108 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local373800336_0023_m_000000_0
2015-02-10 17:25:03,109 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@16030e71
2015-02-10 17:25:03,111 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,111 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4275b35
2015-02-10 17:25:03,112 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-02-10 17:25:03,123 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:03,124 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:03,125 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:03,127 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,127 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local373800336_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:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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)
2015-02-10 17:25:03,132 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] hadoop job job_local373800336_0023 state at FAILED
2015-02-10 17:25:03,132 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] failure info: NA
2015-02-10 17:25:03,134 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events identify failed tasks
2015-02-10 17:25:03,134 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [each.each] task completion events count: 0
2015-02-10 17:25:03,135 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopping all jobs
2015-02-10 17:25:03,135 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-02-10 17:25:03,135 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] stopped all jobs
2015-02-10 17:25:03,136 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-02-10 17:25:03,136 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-02-10 17:25:03,145 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,145 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,155 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,155 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,156 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-02-10 17:25:03,156 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,156 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,156 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,162 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-02-10 17:25:03,174 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,199 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1397703095_0024
2015-02-10 17:25:03,199 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,202 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,202 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1397703095_0024_m_000000_0
2015-02-10 17:25:03,204 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5f048099
2015-02-10 17:25:03,205 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,205 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@656ad447
2015-02-10 17:25:03,206 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-02-10 17:25:03,219 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1397703095_0024_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,221 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,221 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1397703095_0024_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,223 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1397703095_0024_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-02-10 17:25:03,225 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,225 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1397703095_0024_m_000000_0' done.
2015-02-10 17:25:03,225 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1397703095_0024_m_000000_0
2015-02-10 17:25:03,225 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,232 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-02-10 17:25:03,244 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,255 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,256 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-02-10 17:25:03,264 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,265 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,268 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-02-10 17:25:03,276 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,277 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,286 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,287 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,287 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-02-10 17:25:03,287 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,287 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,288 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,288 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-02-10 17:25:03,299 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,321 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1873492252_0025
2015-02-10 17:25:03,321 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,324 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,324 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1873492252_0025_m_000000_0
2015-02-10 17:25:03,325 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@47f9d0e
2015-02-10 17:25:03,326 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,327 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6693f61c
2015-02-10 17:25:03,328 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,330 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,330 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,337 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,337 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-02-10 17:25:03,340 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1873492252_0025_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,341 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,341 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1873492252_0025_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,344 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1873492252_0025_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-02-10 17:25:03,345 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,345 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1873492252_0025_m_000000_0' done.
2015-02-10 17:25:03,346 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1873492252_0025_m_000000_0
2015-02-10 17:25:03,346 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,353 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-02-10 17:25:03,362 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,371 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,373 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-02-10 17:25:03,380 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,381 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-02-10 17:25:03,392 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,392 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,401 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,402 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,402 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-02-10 17:25:03,403 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,403 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,403 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,404 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-02-10 17:25:03,412 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,433 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local2028877780_0026
2015-02-10 17:25:03,433 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,436 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,436 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2028877780_0026_m_000000_0
2015-02-10 17:25:03,438 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3a4346cd
2015-02-10 17:25:03,439 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,439 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@72be8e1
2015-02-10 17:25:03,440 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-02-10 17:25:03,452 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local2028877780_0026_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,454 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,455 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local2028877780_0026_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,457 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2028877780_0026_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-02-10 17:25:03,458 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,458 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2028877780_0026_m_000000_0' done.
2015-02-10 17:25:03,458 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2028877780_0026_m_000000_0
2015-02-10 17:25:03,459 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,466 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-02-10 17:25:03,474 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,484 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,485 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-02-10 17:25:03,493 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,493 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,502 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,502 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,503 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-02-10 17:25:03,503 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,503 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,504 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,504 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-02-10 17:25:03,512 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,532 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local603012380_0027
2015-02-10 17:25:03,533 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,535 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,535 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local603012380_0027_m_000000_0
2015-02-10 17:25:03,536 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@25230534
2015-02-10 17:25:03,537 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,537 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@27b4fe4d
2015-02-10 17:25:03,539 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,548 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,548 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-02-10 17:25:03,551 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local603012380_0027_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,552 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,553 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local603012380_0027_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,555 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local603012380_0027_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-02-10 17:25:03,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,556 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local603012380_0027_m_000000_0' done.
2015-02-10 17:25:03,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local603012380_0027_m_000000_0
2015-02-10 17:25:03,557 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,565 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-02-10 17:25:03,573 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,583 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,584 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-02-10 17:25:03,592 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,592 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,601 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,601 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,602 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-02-10 17:25:03,602 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,602 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,603 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,605 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-02-10 17:25:03,614 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,642 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local45422089_0028
2015-02-10 17:25:03,642 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,644 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,644 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local45422089_0028_m_000000_0
2015-02-10 17:25:03,645 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@27299442
2015-02-10 17:25:03,647 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,647 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@37176e8a
2015-02-10 17:25:03,648 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,657 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,657 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-02-10 17:25:03,660 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local45422089_0028_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,661 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,662 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local45422089_0028_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,664 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local45422089_0028_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-02-10 17:25:03,665 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,665 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local45422089_0028_m_000000_0' done.
2015-02-10 17:25:03,665 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local45422089_0028_m_000000_0
2015-02-10 17:25:03,666 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,674 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-02-10 17:25:03,682 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,692 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,693 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-02-10 17:25:03,701 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,701 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,710 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,710 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,710 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-02-10 17:25:03,711 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,711 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,711 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,712 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-02-10 17:25:03,720 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,740 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local378885321_0029
2015-02-10 17:25:03,740 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,743 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,743 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local378885321_0029_m_000000_0
2015-02-10 17:25:03,744 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4de07d3e
2015-02-10 17:25:03,745 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,745 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@37ff24f
2015-02-10 17:25:03,747 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,756 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-02-10 17:25:03,758 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local378885321_0029_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,760 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,760 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local378885321_0029_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,762 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local378885321_0029_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-02-10 17:25:03,764 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,764 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local378885321_0029_m_000000_0' done.
2015-02-10 17:25:03,764 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local378885321_0029_m_000000_0
2015-02-10 17:25:03,764 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,773 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-02-10 17:25:03,782 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,791 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-02-10 17:25:03,800 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,800 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,809 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,809 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-02-10 17:25:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,811 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,811 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-02-10 17:25:03,819 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,839 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local950349723_0030
2015-02-10 17:25:03,839 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,842 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,842 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local950349723_0030_m_000000_0
2015-02-10 17:25:03,844 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2a5ebf99
2015-02-10 17:25:03,845 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,845 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5cfc644a
2015-02-10 17:25:03,847 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-02-10 17:25:03,860 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local950349723_0030_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,861 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,862 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local950349723_0030_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,864 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local950349723_0030_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-02-10 17:25:03,865 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,866 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local950349723_0030_m_000000_0' done.
2015-02-10 17:25:03,866 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local950349723_0030_m_000000_0
2015-02-10 17:25:03,866 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,871 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-02-10 17:25:03,880 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,889 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,890 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-02-10 17:25:03,898 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,898 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,907 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting
2015-02-10 17:25:03,907 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,907 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-02-10 17:25:03,908 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] parallel execution is enabled: false
2015-02-10 17:25:03,908 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] starting jobs: 1
2015-02-10 17:25:03,908 INFO flow.Flow (BaseFlow.java:logInfo(1378)) - [each.each] allocating threads: 1
2015-02-10 17:25:03,909 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 17:25:03,917 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,936 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] submitted hadoop job: job_local1933820806_0031
2015-02-10 17:25:03,936 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [each.each] tracking url: http://localhost:8080/
2015-02-10 17:25:03,938 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:25:03,939 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1933820806_0031_m_000000_0
2015-02-10 17:25:03,940 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@138bb3fd
2015-02-10 17:25:03,941 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-02-10 17:25:03,941 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@28098d94
2015-02-10 17:25:03,942 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:25:03,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:25:03,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:25:03,952 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-02-10 17:25:03,952 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-02-10 17:25:03,955 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1933820806_0031_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:25:03,957 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2015-02-10 17:25:03,957 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1933820806_0031_m_000000_0 is allowed to commit now
2015-02-10 17:25:03,959 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1933820806_0031_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 17:25:03,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2015-02-10 17:25:03,961 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1933820806_0031_m_000000_0' done.
2015-02-10 17:25:03,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1933820806_0031_m_000000_0
2015-02-10 17:25:03,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:25:03,969 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-02-10 17:25:03,977 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,986 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:25:03,987 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 17:25:03,995 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:25:03,995 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:25:03,998 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'