Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

all > cascading.detail > EveryEveryPipeAssemblyPlatformTest
40

tests
0

failures
1m19.30s

duration
100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 3.191s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 3.222s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 4.049s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 3.141s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 3.145s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.015s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.013s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 3.102s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 3.118s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.019s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 3.123s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 3.113s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 3.112s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.030s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.117s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.101s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.102s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 3.088s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 3.097s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 3.086s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 3.101s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 3.085s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.012s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 3.087s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 3.089s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 3.081s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 3.087s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.013s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.078s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.074s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.092s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 3.088s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 3.083s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 3.083s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 3.081s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 3.075s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.011s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 3.072s passed

Standard output

2015-02-10 12:26:33,458 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 12:26:33,506 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 12:26:33,506 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2015-02-10 12:26:33,596 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,613 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,623 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,633 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,640 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,647 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,653 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,654 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,659 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,664 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,669 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,670 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,671 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,675 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,675 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,676 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,681 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,682 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,688 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,695 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,703 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,711 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,718 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,719 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,723 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,727 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,727 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,728 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,728 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,729 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,733 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,733 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,737 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,737 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,741 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,745 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,748 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,752 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,755 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:33,759 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-02-10 12:26:34,080 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 12:26:34,457 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:34,459 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:34,471 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 1684300AF8764CD894DBF947C54598C0
2015-02-10 12:26:34,687 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 12:26:34,691 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:34,692 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:34,693 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-02-10 12:26:34,693 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:34,694 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:34,694 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:34,697 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-02-10 12:26:34,742 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 12:26:34,791 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:35,011 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0001
2015-02-10 12:26:35,013 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:35,080 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 12:26:35,088 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5aa45a24
2015-02-10 12:26:35,096 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:35,103 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:35,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:35,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:35,181 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:35,182 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-02-10 12:26:35,196 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:35,199 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:35,200 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2015-02-10 12:26:35,206 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-02-10 12:26:38,063 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:38,064 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2015-02-10 12:26:38,074 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-02-10 12:26:38,102 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:38,127 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:38,128 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-02-10 12:26:38,151 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:38,152 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:38,176 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:38,177 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:38,178 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-02-10 12:26:38,178 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:38,179 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:38,179 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:38,180 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-02-10 12:26:38,199 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:38,285 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0002
2015-02-10 12:26:38,285 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:38,289 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3fe88b35
2015-02-10 12:26:38,291 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:38,293 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:38,298 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:38,298 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:38,313 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:38,315 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-02-10 12:26:38,319 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:38,320 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:38,320 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2015-02-10 12:26:38,325 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-02-10 12:26:41,289 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:41,290 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2015-02-10 12:26:41,302 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-02-10 12:26:41,325 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:41,349 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:41,351 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-02-10 12:26:41,372 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:41,373 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:41,397 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:41,398 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:41,398 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-02-10 12:26:41,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:41,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:41,399 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:41,400 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-02-10 12:26:41,420 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:41,491 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0003
2015-02-10 12:26:41,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:41,499 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@19af9e98
2015-02-10 12:26:41,501 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:41,503 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:41,510 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:41,510 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:41,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:41,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-02-10 12:26:41,529 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:41,530 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:41,531 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2015-02-10 12:26:41,537 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-02-10 12:26:44,498 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:44,499 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2015-02-10 12:26:44,509 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-02-10 12:26:44,526 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:44,541 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:44,543 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-02-10 12:26:44,555 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:44,556 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:44,579 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:44,579 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:44,579 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-02-10 12:26:44,580 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:44,580 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:44,580 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:44,581 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-02-10 12:26:44,600 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:44,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0004
2015-02-10 12:26:44,642 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:44,647 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5ab05fcb
2015-02-10 12:26:44,648 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:44,650 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:44,655 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:44,656 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:44,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:44,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-02-10 12:26:44,673 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:44,674 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:44,675 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2015-02-10 12:26:44,680 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-02-10 12:26:47,646 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:47,647 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2015-02-10 12:26:47,658 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-02-10 12:26:47,672 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:47,687 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:47,688 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-02-10 12:26:47,712 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:47,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:47,732 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-02-10 12:26:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:47,734 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-02-10 12:26:47,752 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:47,787 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0005
2015-02-10 12:26:47,788 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:47,792 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2206179e
2015-02-10 12:26:47,794 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:47,795 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:47,800 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:47,800 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:47,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:47,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-02-10 12:26:47,815 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:47,816 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:47,817 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2015-02-10 12:26:47,821 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-02-10 12:26:50,794 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:50,795 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2015-02-10 12:26:50,805 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-02-10 12:26:50,817 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:50,829 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:50,831 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-02-10 12:26:50,840 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:50,841 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:50,860 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:50,861 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:50,861 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-02-10 12:26:50,861 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:50,861 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:50,862 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:50,862 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-02-10 12:26:50,880 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:50,913 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0006
2015-02-10 12:26:50,914 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:50,919 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3219ee8a
2015-02-10 12:26:50,921 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:50,922 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:50,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:50,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:50,936 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:50,937 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-02-10 12:26:50,940 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:50,941 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:50,942 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2015-02-10 12:26:50,945 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-02-10 12:26:53,919 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:53,920 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2015-02-10 12:26:53,931 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-02-10 12:26:53,942 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:53,953 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:53,955 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-02-10 12:26:53,965 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:53,966 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:53,974 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-02-10 12:26:53,984 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:53,985 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:54,004 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:54,004 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:54,004 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-02-10 12:26:54,005 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:54,005 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:54,005 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:54,006 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-02-10 12:26:54,021 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:54,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0007
2015-02-10 12:26:54,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:54,056 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@17496e57
2015-02-10 12:26:54,057 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:54,058 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:54,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:54,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:54,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:54,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-02-10 12:26:54,076 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:54,077 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:54,078 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2015-02-10 12:26:54,081 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-02-10 12:26:57,056 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:26:57,057 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2015-02-10 12:26:57,069 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-02-10 12:26:57,080 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:57,091 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:57,093 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-02-10 12:26:57,102 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:26:57,103 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:26:57,122 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:26:57,122 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:57,122 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-02-10 12:26:57,123 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:26:57,123 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:26:57,123 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:26:57,124 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-02-10 12:26:57,137 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:26:57,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0008
2015-02-10 12:26:57,167 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:26:57,171 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5e1645b9
2015-02-10 12:26:57,173 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:26:57,175 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:26:57,180 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:26:57,180 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:26:57,190 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:26:57,191 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-02-10 12:26:57,194 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:26:57,195 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:26:57,196 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2015-02-10 12:26:57,199 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-02-10 12:27:00,171 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:00,171 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2015-02-10 12:27:00,183 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-02-10 12:27:00,194 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:00,205 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:00,206 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-02-10 12:27:00,215 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:00,215 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:00,234 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:00,234 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:00,235 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-02-10 12:27:00,235 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:00,235 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:00,235 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:00,236 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 12:27:00,249 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:00,278 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0009
2015-02-10 12:27:00,279 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:00,282 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@46d0d843
2015-02-10 12:27:00,284 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:00,285 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:00,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:00,290 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:00,299 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:00,299 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-02-10 12:27:00,302 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:00,303 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:00,304 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0009_m_000000_0 is allowed to commit now
2015-02-10 12:27:00,307 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 12:27:03,282 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:03,283 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0009_m_000000_0' done.
2015-02-10 12:27:03,297 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-02-10 12:27:03,307 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,318 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,319 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-02-10 12:27:03,328 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,329 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,345 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:03,346 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,346 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-02-10 12:27:03,347 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:03,347 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:03,347 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:03,348 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-02-10 12:27:03,360 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,385 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0010
2015-02-10 12:27:03,386 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:03,390 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@477baf4
2015-02-10 12:27:03,391 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:03,392 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:03,396 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:03,397 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:03,407 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,407 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-02-10 12:27:03,410 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,419 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,423 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,425 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,430 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0010 state at FAILED
2015-02-10 12:27:03,430 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:03,431 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:03,431 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:03,432 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:03,435 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-02-10 12:27:03,435 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:03,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-02-10 12:27:03,436 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-02-10 12:27:03,446 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,447 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,467 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-02-10 12:27:03,476 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,477 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,494 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:03,494 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,495 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-02-10 12:27:03,496 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:03,496 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:03,496 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:03,498 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-02-10 12:27:03,510 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,534 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0011
2015-02-10 12:27:03,534 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:03,538 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@72ba007e
2015-02-10 12:27:03,540 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:03,541 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:03,545 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:03,545 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:03,553 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,554 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-02-10 12:27:03,555 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,556 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,556 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,558 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,565 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0011 state at FAILED
2015-02-10 12:27:03,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:03,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:03,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:03,567 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:03,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-02-10 12:27:03,568 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:03,568 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-02-10 12:27:03,569 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-02-10 12:27:03,578 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,578 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,595 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:03,596 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,596 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-02-10 12:27:03,597 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:03,597 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:03,597 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:03,599 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-02-10 12:27:03,611 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,636 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0012
2015-02-10 12:27:03,636 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:03,641 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@38a92aaa
2015-02-10 12:27:03,642 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:03,643 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:03,647 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:03,647 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:03,655 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,655 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-02-10 12:27:03,656 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,657 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,657 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,659 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0012
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:03,667 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0012 state at FAILED
2015-02-10 12:27:03,667 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:03,667 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:03,667 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:03,668 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:03,668 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-02-10 12:27:03,669 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:03,669 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-02-10 12:27:03,670 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-02-10 12:27:03,679 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,679 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,685 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-02-10 12:27:03,694 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:03,695 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:03,710 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:03,710 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,710 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-02-10 12:27:03,711 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:03,711 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:03,711 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:03,713 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-02-10 12:27:03,724 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:03,747 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0013
2015-02-10 12:27:03,748 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:03,751 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@62c8aeb3
2015-02-10 12:27:03,752 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:03,754 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:03,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:03,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:03,765 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:03,766 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-02-10 12:27:03,769 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:03,769 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:03,770 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0013_m_000000_0 is allowed to commit now
2015-02-10 12:27:03,773 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-02-10 12:27:06,751 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:06,752 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0013_m_000000_0' done.
2015-02-10 12:27:06,766 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-02-10 12:27:06,775 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:06,785 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:06,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-02-10 12:27:06,796 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:06,796 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:06,801 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-02-10 12:27:06,809 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:06,810 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:06,824 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:06,824 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:06,824 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-02-10 12:27:06,824 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:06,825 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:06,825 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:06,825 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-02-10 12:27:06,839 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:06,862 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0014
2015-02-10 12:27:06,862 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:06,865 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7a0938f0
2015-02-10 12:27:06,867 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:06,868 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:06,871 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:06,871 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:06,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:06,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-02-10 12:27:06,882 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:06,883 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:06,883 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2015-02-10 12:27:06,886 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-02-10 12:27:09,391 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:09,539 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:09,641 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:09,865 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:09,866 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0014_m_000000_0' done.
2015-02-10 12:27:09,878 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-02-10 12:27:09,887 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:09,897 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:09,899 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-02-10 12:27:09,907 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:09,907 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:09,921 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:09,921 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:09,922 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-02-10 12:27:09,922 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:09,922 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:09,923 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:09,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-02-10 12:27:09,935 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:09,957 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0015
2015-02-10 12:27:09,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:09,961 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@709fa12f
2015-02-10 12:27:09,963 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:09,964 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:09,967 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:09,967 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:09,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:09,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-02-10 12:27:09,978 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:09,979 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:09,979 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0015_m_000000_0 is allowed to commit now
2015-02-10 12:27:09,982 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-02-10 12:27:12,961 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:12,962 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0015_m_000000_0' done.
2015-02-10 12:27:12,967 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-02-10 12:27:12,976 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:12,986 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:12,987 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-02-10 12:27:12,995 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:12,995 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:13,008 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:13,009 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:13,009 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-02-10 12:27:13,011 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:13,011 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:13,011 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:13,011 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-02-10 12:27:13,024 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:13,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0016
2015-02-10 12:27:13,056 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:13,063 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@72d86c58
2015-02-10 12:27:13,067 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:13,068 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:13,072 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:13,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:13,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:13,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-02-10 12:27:13,085 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0016_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:13,086 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:13,087 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0016_m_000000_0 is allowed to commit now
2015-02-10 12:27:13,090 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-02-10 12:27:16,063 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:16,064 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0016_m_000000_0' done.
2015-02-10 12:27:16,067 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-02-10 12:27:16,077 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:16,086 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:16,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-02-10 12:27:16,096 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:16,096 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:16,109 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:16,109 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:16,111 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-02-10 12:27:16,112 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:16,112 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:16,112 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:16,113 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-02-10 12:27:16,123 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:16,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0017
2015-02-10 12:27:16,148 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:16,150 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@65ddcac5
2015-02-10 12:27:16,151 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:16,152 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:16,155 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:16,155 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:16,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:16,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-02-10 12:27:16,167 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0017_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:16,169 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:16,170 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0017_m_000000_0 is allowed to commit now
2015-02-10 12:27:16,172 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-02-10 12:27:19,150 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:19,151 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0017_m_000000_0' done.
2015-02-10 12:27:19,154 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-02-10 12:27:19,164 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:19,173 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:19,174 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-02-10 12:27:19,182 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:19,183 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:19,195 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:19,195 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:19,196 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-02-10 12:27:19,196 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:19,196 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:19,196 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:19,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-02-10 12:27:19,207 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:19,228 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0018
2015-02-10 12:27:19,228 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:19,231 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@387413e8
2015-02-10 12:27:19,232 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:19,233 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:19,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:19,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:19,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:19,244 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-02-10 12:27:19,247 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0018_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:19,248 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:19,248 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0018_m_000000_0 is allowed to commit now
2015-02-10 12:27:19,251 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-02-10 12:27:22,231 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:22,232 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0018_m_000000_0' done.
2015-02-10 12:27:22,244 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-02-10 12:27:22,253 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:22,262 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:22,263 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-02-10 12:27:22,271 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:22,272 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:22,276 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-02-10 12:27:22,284 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:22,284 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:22,296 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:22,297 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:22,297 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-02-10 12:27:22,297 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:22,297 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:22,297 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:22,298 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-02-10 12:27:22,308 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:22,328 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0019
2015-02-10 12:27:22,328 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:22,332 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@35612600
2015-02-10 12:27:22,333 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:22,334 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:22,337 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:22,337 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:22,344 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:22,345 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-02-10 12:27:22,348 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0019_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:22,348 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:22,349 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0019_m_000000_0 is allowed to commit now
2015-02-10 12:27:22,352 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0019_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-02-10 12:27:25,331 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:25,332 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0019_m_000000_0' done.
2015-02-10 12:27:25,345 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-02-10 12:27:25,354 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:25,363 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:25,364 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-02-10 12:27:25,372 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:25,373 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:25,384 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:25,385 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:25,385 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-02-10 12:27:25,385 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:25,385 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:25,385 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:25,386 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-02-10 12:27:25,398 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:25,418 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0020
2015-02-10 12:27:25,418 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:25,421 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7ffccfe3
2015-02-10 12:27:25,422 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:25,423 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:25,426 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:25,426 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:25,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:25,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-02-10 12:27:25,436 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0020_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:25,437 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:25,438 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0020_m_000000_0 is allowed to commit now
2015-02-10 12:27:25,440 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0020_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-02-10 12:27:28,421 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:28,422 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0020_m_000000_0' done.
2015-02-10 12:27:28,425 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-02-10 12:27:28,435 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,444 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,445 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-02-10 12:27:28,454 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:28,454 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:28,465 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:28,466 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,466 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-02-10 12:27:28,466 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:28,466 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:28,466 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:28,467 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-02-10 12:27:28,476 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,496 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0021
2015-02-10 12:27:28,497 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:28,500 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7a4014a0
2015-02-10 12:27:28,501 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:28,502 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:28,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:28,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:28,512 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,512 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-02-10 12:27:28,513 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,514 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,514 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,516 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0021
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,518 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0021 state at FAILED
2015-02-10 12:27:28,519 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:28,519 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:28,519 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:28,519 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:28,520 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-02-10 12:27:28,520 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:28,520 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] shutting down job executor
2015-02-10 12:27:28,521 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] shutdown complete
2015-02-10 12:27:28,523 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-02-10 12:27:28,524 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-02-10 12:27:28,532 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:28,533 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:28,537 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-02-10 12:27:28,545 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:28,545 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:28,556 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:28,556 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,556 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-02-10 12:27:28,556 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:28,556 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:28,557 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:28,557 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-02-10 12:27:28,568 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,594 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0022
2015-02-10 12:27:28,594 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:28,598 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@74a138
2015-02-10 12:27:28,599 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:28,600 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:28,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:28,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:28,611 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,611 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-02-10 12:27:28,612 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,613 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,613 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,615 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0022
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,625 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0022 state at FAILED
2015-02-10 12:27:28,625 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:28,626 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:28,626 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:28,627 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:28,628 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-02-10 12:27:28,628 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:28,628 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-02-10 12:27:28,629 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-02-10 12:27:28,637 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:28,638 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:28,648 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:28,649 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,649 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-02-10 12:27:28,649 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:28,649 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:28,649 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:28,650 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-02-10 12:27:28,659 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,679 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0023
2015-02-10 12:27:28,679 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:28,682 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@611c4041
2015-02-10 12:27:28,683 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:28,684 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:28,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:28,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:28,694 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,694 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-02-10 12:27:28,695 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,696 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,696 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,698 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0023
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-02-10 12:27:28,700 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] hadoop job job_local_0023 state at FAILED
2015-02-10 12:27:28,700 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] failure info: NA
2015-02-10 12:27:28,700 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events identify failed tasks
2015-02-10 12:27:28,700 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [every.every] task completion events count: 0
2015-02-10 12:27:28,701 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopping all jobs
2015-02-10 12:27:28,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-02-10 12:27:28,701 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] stopped all jobs
2015-02-10 12:27:28,702 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-02-10 12:27:28,702 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-02-10 12:27:28,711 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:28,711 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:28,721 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:28,721 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,722 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-02-10 12:27:28,722 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:28,722 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:28,723 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:28,723 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-02-10 12:27:28,733 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:28,753 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0024
2015-02-10 12:27:28,753 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:28,756 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@75dc818d
2015-02-10 12:27:28,757 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:28,758 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:28,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:28,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:28,768 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:28,768 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-02-10 12:27:28,771 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0024_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:28,772 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:28,772 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0024_m_000000_0 is allowed to commit now
2015-02-10 12:27:28,775 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0024_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-02-10 12:27:31,756 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:31,757 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0024_m_000000_0' done.
2015-02-10 12:27:31,769 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-02-10 12:27:31,778 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:31,787 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:31,788 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-02-10 12:27:31,795 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:31,796 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:31,800 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-02-10 12:27:31,807 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:31,807 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:31,817 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:31,817 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:31,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-02-10 12:27:31,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:31,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:31,818 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:31,818 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-02-10 12:27:31,828 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:31,850 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0025
2015-02-10 12:27:31,851 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:31,853 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@38c83cfd
2015-02-10 12:27:31,855 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:31,856 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:31,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:31,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:31,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:31,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-02-10 12:27:31,868 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0025_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:31,869 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:31,869 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0025_m_000000_0 is allowed to commit now
2015-02-10 12:27:31,872 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0025_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-02-10 12:27:34,501 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:34,598 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:34,683 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:34,853 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:34,854 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0025_m_000000_0' done.
2015-02-10 12:27:34,868 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-02-10 12:27:34,877 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:34,886 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:34,887 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-02-10 12:27:34,894 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:34,895 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:34,898 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-02-10 12:27:34,906 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:34,907 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:34,917 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:34,917 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:34,917 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-02-10 12:27:34,918 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:34,918 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:34,918 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:34,919 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-02-10 12:27:34,927 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:34,947 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0026
2015-02-10 12:27:34,947 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:34,950 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4ec4f498
2015-02-10 12:27:34,951 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:34,953 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:34,955 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:34,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:34,963 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:34,963 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-02-10 12:27:34,966 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0026_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:34,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:34,969 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0026_m_000000_0 is allowed to commit now
2015-02-10 12:27:34,972 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0026_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-02-10 12:27:37,950 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:37,951 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0026_m_000000_0' done.
2015-02-10 12:27:37,964 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-02-10 12:27:37,972 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:37,981 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:37,982 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-02-10 12:27:37,990 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:37,990 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:38,000 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:38,000 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:38,000 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-02-10 12:27:38,000 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:38,001 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:38,001 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:38,001 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-02-10 12:27:38,012 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:38,031 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0027
2015-02-10 12:27:38,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:38,034 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@115c6cb
2015-02-10 12:27:38,036 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:38,036 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:38,039 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:38,039 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:38,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:38,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-02-10 12:27:38,049 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0027_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:38,050 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:38,050 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0027_m_000000_0 is allowed to commit now
2015-02-10 12:27:38,053 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0027_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-02-10 12:27:41,034 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:41,035 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0027_m_000000_0' done.
2015-02-10 12:27:41,048 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-02-10 12:27:41,056 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:41,065 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:41,066 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-02-10 12:27:41,073 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:41,074 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:41,083 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:41,083 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:41,083 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-02-10 12:27:41,083 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:41,084 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:41,084 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:41,084 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-02-10 12:27:41,093 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:41,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0028
2015-02-10 12:27:41,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:41,122 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1f76ed77
2015-02-10 12:27:41,123 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:41,124 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:41,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:41,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:41,134 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:41,135 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-02-10 12:27:41,138 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0028_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:41,138 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:41,139 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0028_m_000000_0 is allowed to commit now
2015-02-10 12:27:41,142 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0028_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-02-10 12:27:44,122 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:44,123 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0028_m_000000_0' done.
2015-02-10 12:27:44,135 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-02-10 12:27:44,143 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:44,152 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:44,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-02-10 12:27:44,162 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:44,162 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:44,171 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:44,172 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:44,172 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-02-10 12:27:44,172 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:44,173 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:44,173 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:44,174 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-02-10 12:27:44,184 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:44,202 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0029
2015-02-10 12:27:44,203 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:44,205 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@63425e17
2015-02-10 12:27:44,207 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:44,208 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:44,210 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:44,210 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:44,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:44,217 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-02-10 12:27:44,220 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0029_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:44,220 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:44,221 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0029_m_000000_0 is allowed to commit now
2015-02-10 12:27:44,223 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0029_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-02-10 12:27:47,205 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:47,206 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0029_m_000000_0' done.
2015-02-10 12:27:47,211 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-02-10 12:27:47,219 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:47,228 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:47,229 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-02-10 12:27:47,236 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:47,237 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:47,245 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:47,246 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:47,246 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-02-10 12:27:47,246 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:47,246 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:47,246 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:47,247 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-02-10 12:27:47,256 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:47,275 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0030
2015-02-10 12:27:47,275 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:47,278 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7c97cb70
2015-02-10 12:27:47,279 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:47,280 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:47,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:47,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:47,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:47,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-02-10 12:27:47,292 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0030_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:47,293 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:47,293 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0030_m_000000_0 is allowed to commit now
2015-02-10 12:27:47,296 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0030_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-02-10 12:27:50,278 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:50,279 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0030_m_000000_0' done.
2015-02-10 12:27:50,292 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-02-10 12:27:50,300 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:50,309 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:50,310 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-02-10 12:27:50,318 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:50,318 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:50,326 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every] starting
2015-02-10 12:27:50,327 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:50,327 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-02-10 12:27:50,327 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  parallel execution is enabled: false
2015-02-10 12:27:50,327 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  starting jobs: 1
2015-02-10 12:27:50,327 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [every.every]  allocating threads: 1
2015-02-10 12:27:50,328 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 12:27:50,337 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:50,356 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] submitted hadoop job: job_local_0031
2015-02-10 12:27:50,357 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [every.every] tracking url: http://localhost:8080/
2015-02-10 12:27:50,359 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6f6827b5
2015-02-10 12:27:50,360 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2015-02-10 12:27:50,361 INFO  mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2015-02-10 12:27:50,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 12:27:50,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 12:27:50,370 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2015-02-10 12:27:50,370 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-02-10 12:27:50,374 INFO  mapred.Task (Task.java:done(847)) - Task:attempt_local_0031_m_000000_0 is done. And is in the process of commiting
2015-02-10 12:27:50,374 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2015-02-10 12:27:50,375 INFO  mapred.Task (Task.java:commit(1000)) - Task attempt_local_0031_m_000000_0 is allowed to commit now
2015-02-10 12:27:50,377 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0031_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 12:27:53,359 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/classes/test/data/nums.20.txt:0+51
2015-02-10 12:27:53,360 INFO  mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0031_m_000000_0' done.
2015-02-10 12:27:53,364 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-02-10 12:27:53,372 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:53,381 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 12:27:53,382 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-02-10 12:27:53,390 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 12:27:53,390 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 12:27:53,393 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'