2013-11-20 14:38:23,197 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 14:38:23,222 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 14:38:23,222 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2013-11-20 14:38:23,258 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,274 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,283 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,292 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,299 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,306 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,312 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,313 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,318 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,323 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,328 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,329 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,329 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,331 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,332 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,332 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,337 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,338 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,343 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,350 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,357 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,364 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,380 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,380 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,387 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,394 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,395 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,395 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,396 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,396 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,400 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,400 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,403 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,404 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,407 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,411 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,414 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,417 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,420 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,423 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-11-20 14:38:23,589 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 14:38:23,930 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:23,933 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:23,948 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 198615EEA74D4F169C4CB86FCD653BB6
2013-11-20 14:38:24,136 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 14:38:24,139 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:24,140 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:24,140 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-11-20 14:38:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:24,141 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:24,143 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:24,187 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 14:38:24,252 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-11-20 14:38:24,258 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:24,473 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local50656556_0001
2013-11-20 14:38:24,505 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:24,509 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local50656556_0001_m_000000_0
2013-11-20 14:38:24,563 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 14:38:24,571 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@49f10a67
2013-11-20 14:38:24,580 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:24,581 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1220b36
2013-11-20 14:38:24,588 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:24,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:24,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:24,659 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:24,660 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-11-20 14:38:24,673 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local50656556_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:24,678 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:24,679 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local50656556_0001_m_000000_0 is allowed to commit now
2013-11-20 14:38:24,683 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local50656556_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:24,685 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:24,686 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local50656556_0001_m_000000_0' done.
2013-11-20 14:38:24,686 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local50656556_0001_m_000000_0
2013-11-20 14:38:24,686 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:24,700 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2013-11-20 14:38:24,724 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:24,749 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:24,751 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-11-20 14:38:24,773 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:24,773 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:24,795 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:24,797 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:24,798 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-11-20 14:38:24,799 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:24,800 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:24,801 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:24,802 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2013-11-20 14:38:24,817 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:24,916 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1740292388_0002
2013-11-20 14:38:24,919 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:24,919 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1740292388_0002_m_000000_0
2013-11-20 14:38:24,923 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@20dccfab
2013-11-20 14:38:24,925 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:24,926 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@45d1c3cd
2013-11-20 14:38:24,927 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:24,935 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:24,935 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:24,947 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:24,947 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-11-20 14:38:24,950 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1740292388_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:24,952 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:24,953 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1740292388_0002_m_000000_0 is allowed to commit now
2013-11-20 14:38:24,956 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1740292388_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-11-20 14:38:24,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:24,958 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1740292388_0002_m_000000_0' done.
2013-11-20 14:38:24,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1740292388_0002_m_000000_0
2013-11-20 14:38:24,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:24,968 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2013-11-20 14:38:24,990 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,014 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,017 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-11-20 14:38:25,036 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,036 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,058 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:25,060 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,060 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-11-20 14:38:25,061 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:25,061 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:25,062 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:25,063 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2013-11-20 14:38:25,078 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,144 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1286056672_0003
2013-11-20 14:38:25,148 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:25,148 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1286056672_0003_m_000000_0
2013-11-20 14:38:25,150 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7cbdb375
2013-11-20 14:38:25,152 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:25,152 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2377ff35
2013-11-20 14:38:25,154 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:25,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:25,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:25,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-11-20 14:38:25,175 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1286056672_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:25,177 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:25,178 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1286056672_0003_m_000000_0 is allowed to commit now
2013-11-20 14:38:25,182 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1286056672_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-11-20 14:38:25,183 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:25,184 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1286056672_0003_m_000000_0' done.
2013-11-20 14:38:25,184 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1286056672_0003_m_000000_0
2013-11-20 14:38:25,184 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:25,196 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2013-11-20 14:38:25,215 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,234 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,236 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-11-20 14:38:25,252 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,253 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,276 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:25,276 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,277 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-11-20 14:38:25,277 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:25,277 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:25,277 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:25,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2013-11-20 14:38:25,296 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local307474587_0004
2013-11-20 14:38:25,348 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:25,348 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local307474587_0004_m_000000_0
2013-11-20 14:38:25,351 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@92ca580
2013-11-20 14:38:25,353 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:25,353 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@455dd32a
2013-11-20 14:38:25,354 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:25,359 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:25,360 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:25,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-11-20 14:38:25,374 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local307474587_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:25,376 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:25,377 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local307474587_0004_m_000000_0 is allowed to commit now
2013-11-20 14:38:25,380 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local307474587_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-11-20 14:38:25,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:25,382 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local307474587_0004_m_000000_0' done.
2013-11-20 14:38:25,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local307474587_0004_m_000000_0
2013-11-20 14:38:25,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:25,397 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2013-11-20 14:38:25,411 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,426 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,427 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-11-20 14:38:25,441 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,442 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,461 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:25,461 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,461 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-11-20 14:38:25,462 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:25,462 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:25,462 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:25,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:25,481 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,533 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local2100956669_0005
2013-11-20 14:38:25,537 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:25,537 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2100956669_0005_m_000000_0
2013-11-20 14:38:25,541 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4f549ceb
2013-11-20 14:38:25,544 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:25,544 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@66e8c7db
2013-11-20 14:38:25,546 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:25,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:25,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:25,564 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,565 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-11-20 14:38:25,568 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local2100956669_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:25,571 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:25,571 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local2100956669_0005_m_000000_0 is allowed to commit now
2013-11-20 14:38:25,575 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2100956669_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:25,576 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:25,577 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2100956669_0005_m_000000_0' done.
2013-11-20 14:38:25,577 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2100956669_0005_m_000000_0
2013-11-20 14:38:25,577 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:25,585 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2013-11-20 14:38:25,600 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,615 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,617 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-11-20 14:38:25,627 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,628 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,651 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:25,652 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,652 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-11-20 14:38:25,652 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:25,652 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:25,653 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:25,655 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:25,671 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,711 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1883288713_0006
2013-11-20 14:38:25,715 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:25,715 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1883288713_0006_m_000000_0
2013-11-20 14:38:25,717 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@72a60191
2013-11-20 14:38:25,719 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:25,719 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@71412b61
2013-11-20 14:38:25,720 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:25,724 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:25,725 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:25,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-11-20 14:38:25,737 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1883288713_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:25,739 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:25,739 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1883288713_0006_m_000000_0 is allowed to commit now
2013-11-20 14:38:25,743 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1883288713_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:25,744 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:25,744 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1883288713_0006_m_000000_0' done.
2013-11-20 14:38:25,745 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1883288713_0006_m_000000_0
2013-11-20 14:38:25,745 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:25,754 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2013-11-20 14:38:25,766 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,886 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,888 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-11-20 14:38:25,898 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,898 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,905 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2013-11-20 14:38:25,914 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:25,914 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:25,930 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-11-20 14:38:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:25,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:25,932 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:25,961 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:25,995 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local17542041_0007
2013-11-20 14:38:25,997 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:25,997 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local17542041_0007_m_000000_0
2013-11-20 14:38:25,999 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@318c69a9
2013-11-20 14:38:26,000 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,001 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@40944dbd
2013-11-20 14:38:26,002 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,015 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,015 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-11-20 14:38:26,019 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local17542041_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:26,021 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:26,022 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local17542041_0007_m_000000_0 is allowed to commit now
2013-11-20 14:38:26,025 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local17542041_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:26,026 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:26,026 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local17542041_0007_m_000000_0' done.
2013-11-20 14:38:26,026 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local17542041_0007_m_000000_0
2013-11-20 14:38:26,027 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,037 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2013-11-20 14:38:26,048 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,060 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,061 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-11-20 14:38:26,070 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,070 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,086 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,086 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-11-20 14:38:26,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,087 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:26,098 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,128 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local122991622_0008
2013-11-20 14:38:26,131 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,131 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local122991622_0008_m_000000_0
2013-11-20 14:38:26,134 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@36598d00
2013-11-20 14:38:26,136 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,137 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@58b45130
2013-11-20 14:38:26,139 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,144 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-11-20 14:38:26,156 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local122991622_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:26,159 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:26,159 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local122991622_0008_m_000000_0 is allowed to commit now
2013-11-20 14:38:26,162 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local122991622_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:26,164 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:26,165 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local122991622_0008_m_000000_0' done.
2013-11-20 14:38:26,165 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local122991622_0008_m_000000_0
2013-11-20 14:38:26,165 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2013-11-20 14:38:26,188 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,199 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,201 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-11-20 14:38:26,209 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,210 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,224 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,224 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,224 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-11-20 14:38:26,225 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,225 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,225 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,225 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:26,238 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,266 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local768075863_0009
2013-11-20 14:38:26,268 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,269 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local768075863_0009_m_000000_0
2013-11-20 14:38:26,270 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b31fd9
2013-11-20 14:38:26,272 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,273 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@304caadb
2013-11-20 14:38:26,275 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,279 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,279 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,287 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-11-20 14:38:26,291 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local768075863_0009_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:26,293 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:26,293 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local768075863_0009_m_000000_0 is allowed to commit now
2013-11-20 14:38:26,296 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local768075863_0009_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:26,298 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:26,298 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local768075863_0009_m_000000_0' done.
2013-11-20 14:38:26,298 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local768075863_0009_m_000000_0
2013-11-20 14:38:26,298 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,308 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2013-11-20 14:38:26,318 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,332 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,333 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-11-20 14:38:26,342 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,342 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,358 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,358 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,359 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-11-20 14:38:26,359 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,359 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,359 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,360 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:26,372 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local211861050_0010
2013-11-20 14:38:26,402 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,402 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local211861050_0010_m_000000_0
2013-11-20 14:38:26,404 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@32935741
2013-11-20 14:38:26,406 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,406 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2e027538
2013-11-20 14:38:26,408 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,412 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,412 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,420 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,420 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-11-20 14:38:26,422 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,424 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,426 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,427 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,428 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local211861050_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,430 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:26,431 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:26,431 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:26,431 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:26,432 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:26,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2013-11-20 14:38:26,433 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2013-11-20 14:38:26,445 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,446 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,452 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2013-11-20 14:38:26,462 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,462 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,478 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,479 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,479 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-11-20 14:38:26,480 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,480 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,480 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,481 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:26,493 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,519 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local90041090_0011
2013-11-20 14:38:26,523 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,523 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local90041090_0011_m_000000_0
2013-11-20 14:38:26,545 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@44ec366a
2013-11-20 14:38:26,547 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,547 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@27e3bfb6
2013-11-20 14:38:26,548 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-11-20 14:38:26,560 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,561 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,562 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,563 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,564 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local90041090_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,571 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:26,572 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:26,572 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:26,573 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:26,573 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:26,574 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2013-11-20 14:38:26,574 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2013-11-20 14:38:26,585 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,586 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,602 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,603 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,603 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-11-20 14:38:26,604 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,604 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,604 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,606 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:26,618 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local109978109_0012
2013-11-20 14:38:26,653 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,653 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local109978109_0012_m_000000_0
2013-11-20 14:38:26,655 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3764f8d4
2013-11-20 14:38:26,657 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,657 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5d3d0fea
2013-11-20 14:38:26,658 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-11-20 14:38:26,671 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,672 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,673 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,674 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,675 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local109978109_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:26,685 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:26,685 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:26,686 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:26,686 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:26,687 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:26,687 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2013-11-20 14:38:26,688 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2013-11-20 14:38:26,696 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,697 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,702 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2013-11-20 14:38:26,710 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,711 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,725 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,726 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,726 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-11-20 14:38:26,727 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,727 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,727 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,728 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:26,739 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,764 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local162107298_0013
2013-11-20 14:38:26,769 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,769 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local162107298_0013_m_000000_0
2013-11-20 14:38:26,771 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2da15597
2013-11-20 14:38:26,773 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,774 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1875303f
2013-11-20 14:38:26,775 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,787 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,787 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-11-20 14:38:26,790 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local162107298_0013_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:26,792 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:26,793 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local162107298_0013_m_000000_0 is allowed to commit now
2013-11-20 14:38:26,796 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local162107298_0013_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:26,798 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:26,798 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local162107298_0013_m_000000_0' done.
2013-11-20 14:38:26,798 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local162107298_0013_m_000000_0
2013-11-20 14:38:26,798 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,811 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2013-11-20 14:38:26,821 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,832 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,834 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-11-20 14:38:26,842 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,843 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,847 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2013-11-20 14:38:26,857 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:26,858 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:26,871 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:26,871 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,872 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-11-20 14:38:26,872 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:26,872 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:26,872 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:26,873 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2013-11-20 14:38:26,885 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,925 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1120258510_0014
2013-11-20 14:38:26,929 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:26,930 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1120258510_0014_m_000000_0
2013-11-20 14:38:26,932 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@381172c5
2013-11-20 14:38:26,934 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:26,935 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3ca1d92a
2013-11-20 14:38:26,937 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:26,941 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:26,942 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:26,949 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:26,950 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-11-20 14:38:26,953 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1120258510_0014_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:26,955 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:26,956 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1120258510_0014_m_000000_0 is allowed to commit now
2013-11-20 14:38:26,959 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1120258510_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-11-20 14:38:26,960 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:26,961 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1120258510_0014_m_000000_0' done.
2013-11-20 14:38:26,961 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1120258510_0014_m_000000_0
2013-11-20 14:38:26,962 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:26,972 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2013-11-20 14:38:26,986 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:26,998 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,000 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-11-20 14:38:27,008 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,009 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,024 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,024 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,024 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-11-20 14:38:27,025 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,025 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,025 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,026 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2013-11-20 14:38:27,037 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,061 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local192916831_0015
2013-11-20 14:38:27,065 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,065 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local192916831_0015_m_000000_0
2013-11-20 14:38:27,067 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@31b27882
2013-11-20 14:38:27,068 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,069 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@63fa8d3b
2013-11-20 14:38:27,070 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,073 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,073 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,080 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-11-20 14:38:27,083 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local192916831_0015_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,085 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,085 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local192916831_0015_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,088 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local192916831_0015_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-11-20 14:38:27,090 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,090 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local192916831_0015_m_000000_0' done.
2013-11-20 14:38:27,090 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local192916831_0015_m_000000_0
2013-11-20 14:38:27,090 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,106 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2013-11-20 14:38:27,120 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,132 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,134 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-11-20 14:38:27,143 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,143 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,156 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,157 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,157 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-11-20 14:38:27,158 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,159 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,159 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,161 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2013-11-20 14:38:27,170 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,194 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local154540922_0016
2013-11-20 14:38:27,198 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,198 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local154540922_0016_m_000000_0
2013-11-20 14:38:27,199 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6601879b
2013-11-20 14:38:27,202 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,202 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@21ff3fcf
2013-11-20 14:38:27,203 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,206 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,206 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-11-20 14:38:27,216 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local154540922_0016_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,217 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,218 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local154540922_0016_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,220 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local154540922_0016_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-11-20 14:38:27,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,222 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local154540922_0016_m_000000_0' done.
2013-11-20 14:38:27,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local154540922_0016_m_000000_0
2013-11-20 14:38:27,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,227 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2013-11-20 14:38:27,237 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,250 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,252 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-11-20 14:38:27,260 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,261 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,272 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,272 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,272 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-11-20 14:38:27,273 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,273 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,273 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,274 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:27,284 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local343555422_0017
2013-11-20 14:38:27,313 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,313 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local343555422_0017_m_000000_0
2013-11-20 14:38:27,315 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@538787fd
2013-11-20 14:38:27,316 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,316 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@19e7ce87
2013-11-20 14:38:27,317 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,320 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,321 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-11-20 14:38:27,330 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local343555422_0017_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,332 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,333 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local343555422_0017_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,335 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local343555422_0017_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:27,337 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,337 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local343555422_0017_m_000000_0' done.
2013-11-20 14:38:27,337 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local343555422_0017_m_000000_0
2013-11-20 14:38:27,338 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,354 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2013-11-20 14:38:27,364 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,375 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,376 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-11-20 14:38:27,385 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,385 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,397 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,397 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,398 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-11-20 14:38:27,398 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,398 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,398 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,399 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:27,407 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,428 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local152632482_0018
2013-11-20 14:38:27,431 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,431 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local152632482_0018_m_000000_0
2013-11-20 14:38:27,432 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@31ccbefe
2013-11-20 14:38:27,433 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,434 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@47a6ac39
2013-11-20 14:38:27,435 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,445 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,445 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-11-20 14:38:27,448 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local152632482_0018_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,450 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,450 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local152632482_0018_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,453 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local152632482_0018_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:27,454 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,454 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local152632482_0018_m_000000_0' done.
2013-11-20 14:38:27,455 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local152632482_0018_m_000000_0
2013-11-20 14:38:27,455 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,462 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2013-11-20 14:38:27,471 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,480 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,481 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-11-20 14:38:27,488 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,489 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,493 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2013-11-20 14:38:27,501 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,501 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,514 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,514 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,514 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-11-20 14:38:27,514 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,515 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,515 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,515 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:27,524 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,548 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1246196993_0019
2013-11-20 14:38:27,551 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,551 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1246196993_0019_m_000000_0
2013-11-20 14:38:27,553 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@e1641c0
2013-11-20 14:38:27,555 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,555 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2f67d81
2013-11-20 14:38:27,556 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,565 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,565 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-11-20 14:38:27,568 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1246196993_0019_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,570 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,570 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1246196993_0019_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,573 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1246196993_0019_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:27,574 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,574 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1246196993_0019_m_000000_0' done.
2013-11-20 14:38:27,575 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1246196993_0019_m_000000_0
2013-11-20 14:38:27,575 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2013-11-20 14:38:27,590 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,600 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,602 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-11-20 14:38:27,611 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,611 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,622 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,622 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,622 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-11-20 14:38:27,622 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,623 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,623 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,623 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:27,632 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,655 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1145811627_0020
2013-11-20 14:38:27,658 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,658 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1145811627_0020_m_000000_0
2013-11-20 14:38:27,660 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1b219665
2013-11-20 14:38:27,662 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,662 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@649e4dc0
2013-11-20 14:38:27,663 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,666 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-11-20 14:38:27,678 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1145811627_0020_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:27,680 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:27,681 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1145811627_0020_m_000000_0 is allowed to commit now
2013-11-20 14:38:27,686 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1145811627_0020_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:27,687 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:27,688 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1145811627_0020_m_000000_0' done.
2013-11-20 14:38:27,688 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1145811627_0020_m_000000_0
2013-11-20 14:38:27,688 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,698 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2013-11-20 14:38:27,707 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,720 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,722 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-11-20 14:38:27,731 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,731 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,742 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,742 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,742 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-11-20 14:38:27,743 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,743 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,743 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,744 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-11-20 14:38:27,752 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,779 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1875925895_0021
2013-11-20 14:38:27,781 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,782 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1875925895_0021_m_000000_0
2013-11-20 14:38:27,784 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@75f10df7
2013-11-20 14:38:27,786 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,786 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4e823618
2013-11-20 14:38:27,787 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,798 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-11-20 14:38:27,798 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,799 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,800 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,801 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,802 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1875925895_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,810 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:27,810 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:27,811 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:27,811 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-11-20 14:38:27,812 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:27,812 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2013-11-20 14:38:27,813 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2013-11-20 14:38:27,824 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,825 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,829 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2013-11-20 14:38:27,838 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,839 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,850 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,851 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,851 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-11-20 14:38:27,851 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,852 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,852 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:27,861 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,888 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1683723607_0022
2013-11-20 14:38:27,891 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,892 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1683723607_0022_m_000000_0
2013-11-20 14:38:27,894 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@cb551e4
2013-11-20 14:38:27,895 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,896 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5d5cd49f
2013-11-20 14:38:27,897 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,900 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,900 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-11-20 14:38:27,908 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,919 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,920 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,921 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:27,922 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1683723607_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:27,929 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:27,930 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:27,930 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:27,930 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:27,931 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:27,931 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2013-11-20 14:38:27,931 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2013-11-20 14:38:27,939 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:27,940 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:27,950 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-11-20 14:38:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:27,952 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:27,960 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:27,982 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1821563664_0023
2013-11-20 14:38:27,984 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:27,984 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1821563664_0023_m_000000_0
2013-11-20 14:38:27,986 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4be0bf98
2013-11-20 14:38:27,988 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:27,988 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5635378d
2013-11-20 14:38:27,989 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:27,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:27,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:27,998 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:27,998 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-11-20 14:38:27,999 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:28,004 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:28,008 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:28,015 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,016 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1821563664_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2013-11-20 14:38:28,023 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-11-20 14:38:28,023 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-11-20 14:38:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-11-20 14:38:28,024 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-11-20 14:38:28,025 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2013-11-20 14:38:28,025 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2013-11-20 14:38:28,033 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,034 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,043 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,043 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,044 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-11-20 14:38:28,044 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,044 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,044 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,045 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:28,053 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,076 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local887658185_0024
2013-11-20 14:38:28,078 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,078 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local887658185_0024_m_000000_0
2013-11-20 14:38:28,081 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2853d34c
2013-11-20 14:38:28,082 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,082 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1bf5cc7d
2013-11-20 14:38:28,083 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,086 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,086 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-11-20 14:38:28,095 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local887658185_0024_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,096 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,097 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local887658185_0024_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,099 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local887658185_0024_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:28,100 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,101 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local887658185_0024_m_000000_0' done.
2013-11-20 14:38:28,101 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local887658185_0024_m_000000_0
2013-11-20 14:38:28,101 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,108 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2013-11-20 14:38:28,116 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,125 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,127 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-11-20 14:38:28,134 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,135 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,138 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2013-11-20 14:38:28,146 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,146 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,154 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,155 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,155 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-11-20 14:38:28,155 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,155 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,155 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,156 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:28,165 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local579983871_0025
2013-11-20 14:38:28,189 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,190 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local579983871_0025_m_000000_0
2013-11-20 14:38:28,191 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@14f30093
2013-11-20 14:38:28,192 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,193 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@47d77d9e
2013-11-20 14:38:28,194 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-11-20 14:38:28,205 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local579983871_0025_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,208 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,208 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local579983871_0025_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,211 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local579983871_0025_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:28,213 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,213 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local579983871_0025_m_000000_0' done.
2013-11-20 14:38:28,213 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local579983871_0025_m_000000_0
2013-11-20 14:38:28,214 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,219 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2013-11-20 14:38:28,228 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,237 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,238 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-11-20 14:38:28,245 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,246 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,249 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2013-11-20 14:38:28,256 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,257 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-11-20 14:38:28,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,266 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,266 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:28,274 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,297 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1718235994_0026
2013-11-20 14:38:28,300 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,300 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1718235994_0026_m_000000_0
2013-11-20 14:38:28,301 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@34b172ef
2013-11-20 14:38:28,302 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,302 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3316f2e6
2013-11-20 14:38:28,303 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,305 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,306 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-11-20 14:38:28,314 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1718235994_0026_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,315 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,315 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1718235994_0026_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,318 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1718235994_0026_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:28,319 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,319 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1718235994_0026_m_000000_0' done.
2013-11-20 14:38:28,320 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1718235994_0026_m_000000_0
2013-11-20 14:38:28,320 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,329 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2013-11-20 14:38:28,338 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,348 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,349 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-11-20 14:38:28,356 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,357 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,364 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,365 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,365 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-11-20 14:38:28,365 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,365 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,365 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,366 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2013-11-20 14:38:28,374 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1843151680_0027
2013-11-20 14:38:28,397 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,397 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1843151680_0027_m_000000_0
2013-11-20 14:38:28,399 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3fa04c26
2013-11-20 14:38:28,400 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,400 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7d399ae5
2013-11-20 14:38:28,401 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,408 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-11-20 14:38:28,411 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1843151680_0027_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,412 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,413 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1843151680_0027_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,415 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1843151680_0027_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-11-20 14:38:28,416 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,416 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1843151680_0027_m_000000_0' done.
2013-11-20 14:38:28,416 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1843151680_0027_m_000000_0
2013-11-20 14:38:28,416 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,427 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2013-11-20 14:38:28,435 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,445 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,447 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-11-20 14:38:28,453 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,454 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,462 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,463 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,463 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-11-20 14:38:28,463 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,463 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,463 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2013-11-20 14:38:28,472 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,496 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local712757849_0028
2013-11-20 14:38:28,500 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,500 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local712757849_0028_m_000000_0
2013-11-20 14:38:28,502 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@570f35d1
2013-11-20 14:38:28,504 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,504 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@29ac0292
2013-11-20 14:38:28,506 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,509 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,509 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,515 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,515 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-11-20 14:38:28,518 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local712757849_0028_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,519 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,519 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local712757849_0028_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,521 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local712757849_0028_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-11-20 14:38:28,523 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,523 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local712757849_0028_m_000000_0' done.
2013-11-20 14:38:28,523 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local712757849_0028_m_000000_0
2013-11-20 14:38:28,523 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,529 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2013-11-20 14:38:28,536 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,545 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,546 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-11-20 14:38:28,553 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,553 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,561 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,561 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,561 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-11-20 14:38:28,561 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,561 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,562 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,562 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:28,570 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,588 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1786448066_0029
2013-11-20 14:38:28,592 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,592 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1786448066_0029_m_000000_0
2013-11-20 14:38:28,594 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1bdbbaab
2013-11-20 14:38:28,595 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,595 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5d73b35d
2013-11-20 14:38:28,596 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,598 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,604 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,604 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-11-20 14:38:28,607 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1786448066_0029_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,609 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,609 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1786448066_0029_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,611 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1786448066_0029_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:28,612 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,613 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1786448066_0029_m_000000_0' done.
2013-11-20 14:38:28,613 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1786448066_0029_m_000000_0
2013-11-20 14:38:28,613 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,621 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2013-11-20 14:38:28,629 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,639 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-11-20 14:38:28,647 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,647 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,656 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,657 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:28,665 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,687 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local882097687_0030
2013-11-20 14:38:28,689 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,690 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local882097687_0030_m_000000_0
2013-11-20 14:38:28,691 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7f7d2d70
2013-11-20 14:38:28,692 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,692 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6f6827b5
2013-11-20 14:38:28,693 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-11-20 14:38:28,704 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local882097687_0030_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,705 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,705 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local882097687_0030_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,708 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local882097687_0030_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:28,709 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,709 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local882097687_0030_m_000000_0' done.
2013-11-20 14:38:28,709 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local882097687_0030_m_000000_0
2013-11-20 14:38:28,709 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,719 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2013-11-20 14:38:28,728 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,737 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,738 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-11-20 14:38:28,745 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,745 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,753 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-11-20 14:38:28,754 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,754 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-11-20 14:38:28,754 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] parallel execution is enabled: false
2013-11-20 14:38:28,754 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting jobs: 1
2013-11-20 14:38:28,754 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] allocating threads: 1
2013-11-20 14:38:28,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:28,763 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,782 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local1639319448_0031
2013-11-20 14:38:28,784 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:38:28,785 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1639319448_0031_m_000000_0
2013-11-20 14:38:28,786 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@75ad44f6
2013-11-20 14:38:28,787 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt
2013-11-20 14:38:28,787 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6810a098
2013-11-20 14:38:28,788 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:38:28,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:38:28,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:38:28,796 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2013-11-20 14:38:28,796 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-11-20 14:38:28,799 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1639319448_0031_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:38:28,800 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2013-11-20 14:38:28,801 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1639319448_0031_m_000000_0 is allowed to commit now
2013-11-20 14:38:28,803 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1639319448_0031_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:28,804 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/nums.20.txt:0+51
2013-11-20 14:38:28,804 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1639319448_0031_m_000000_0' done.
2013-11-20 14:38:28,804 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1639319448_0031_m_000000_0
2013-11-20 14:38:28,804 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:38:28,815 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2013-11-20 14:38:28,822 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,831 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:38:28,833 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-11-20 14:38:28,839 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:38:28,840 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:38:28,843 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'