2015-08-14 04:13:46,641 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 04:13:46,704 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,704 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2015-08-14 04:13:46,789 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,808 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,818 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,828 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,834 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,842 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,848 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,849 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,854 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,859 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,864 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,865 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,866 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,868 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,868 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,869 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,874 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,875 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,880 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,890 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,897 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,905 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,912 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,913 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,920 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,927 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,927 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,928 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,928 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,929 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,932 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,933 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,936 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,937 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,940 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,944 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,948 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,951 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,956 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:46,959 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 04:13:47,276 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 04:13:47,901 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 04:13:48,055 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 04:13:48,167 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:48,169 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:48,182 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: A72583BA04214C03BA6AF832744BA23B
2015-08-14 04:13:48,393 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 04:13:48,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:48,395 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:48,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 04:13:48,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:48,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:48,396 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:48,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-14 04:13:49,161 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity901441478/.staging/job_local901441478_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:49,162 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity901441478/.staging/job_local901441478_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:49,354 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local901441478_0001/job_local901441478_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:49,355 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local901441478_0001/job_local901441478_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:49,370 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local901441478_0001
2015-08-14 04:13:49,371 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:49,485 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:49,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:49,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:49,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:49,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 04:13:49,648 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-14 04:13:49,739 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-08-14 04:13:49,769 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:49,770 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:49,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:49,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:49,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 04:13:49,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:49,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:49,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:49,810 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-14 04:13:49,956 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity518763463/.staging/job_local518763463_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:49,956 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity518763463/.staging/job_local518763463_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,043 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local518763463_0002/job_local518763463_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:50,044 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local518763463_0002/job_local518763463_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,046 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local518763463_0002
2015-08-14 04:13:50,047 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:50,056 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:50,069 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:50,070 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:50,082 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:50,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 04:13:50,116 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-14 04:13:50,203 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-14 04:13:50,229 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:50,229 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:50,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:50,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:50,257 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 04:13:50,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:50,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:50,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:50,259 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-14 04:13:50,396 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity404947264/.staging/job_local404947264_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:50,398 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity404947264/.staging/job_local404947264_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,483 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local404947264_0003/job_local404947264_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:50,484 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local404947264_0003/job_local404947264_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,486 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local404947264_0003
2015-08-14 04:13:50,488 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:50,499 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:50,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:50,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:50,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:50,527 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 04:13:50,568 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-14 04:13:50,666 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-14 04:13:50,698 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:50,699 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:50,731 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:50,732 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:50,733 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 04:13:50,734 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:50,734 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:50,735 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:50,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-14 04:13:50,866 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1524243442/.staging/job_local1524243442_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:50,866 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1524243442/.staging/job_local1524243442_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,949 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1524243442_0004/job_local1524243442_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:50,949 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1524243442_0004/job_local1524243442_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:50,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1524243442_0004
2015-08-14 04:13:50,951 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:50,959 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:50,970 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:50,970 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:50,980 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:50,981 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 04:13:51,010 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-14 04:13:51,079 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-14 04:13:51,100 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:51,101 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:51,126 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:51,127 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:51,127 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 04:13:51,127 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:51,128 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:51,128 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:51,129 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-14 04:13:51,221 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2076572346/.staging/job_local2076572346_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,222 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2076572346/.staging/job_local2076572346_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,278 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2076572346_0005/job_local2076572346_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,279 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2076572346_0005/job_local2076572346_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,280 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local2076572346_0005
2015-08-14 04:13:51,281 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:51,289 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:51,300 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:51,300 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:51,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:51,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 04:13:51,338 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-14 04:13:51,408 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-14 04:13:51,429 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:51,430 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 04:13:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:51,454 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:51,455 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:51,456 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-14 04:13:51,572 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1453818824/.staging/job_local1453818824_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,572 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1453818824/.staging/job_local1453818824_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,636 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1453818824_0006/job_local1453818824_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,637 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1453818824_0006/job_local1453818824_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,639 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1453818824_0006
2015-08-14 04:13:51,639 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:51,647 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:51,658 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:51,659 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:51,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:51,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 04:13:51,697 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-14 04:13:51,765 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-14 04:13:51,784 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:51,785 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:51,793 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-14 04:13:51,812 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:51,813 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:51,833 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:51,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:51,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 04:13:51,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:51,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:51,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:51,835 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-14 04:13:51,922 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity53879589/.staging/job_local53879589_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,923 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity53879589/.staging/job_local53879589_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,976 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local53879589_0007/job_local53879589_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:51,976 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local53879589_0007/job_local53879589_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:51,977 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local53879589_0007
2015-08-14 04:13:51,978 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:51,985 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:51,995 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:51,995 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:52,005 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 04:13:52,034 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-14 04:13:52,102 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-14 04:13:52,123 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:52,124 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:52,147 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:52,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,148 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 04:13:52,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:52,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:52,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:52,150 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-14 04:13:52,246 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1359090730/.staging/job_local1359090730_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,247 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1359090730/.staging/job_local1359090730_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,302 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1359090730_0008/job_local1359090730_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,303 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1359090730_0008/job_local1359090730_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,305 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1359090730_0008
2015-08-14 04:13:52,306 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:52,312 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:52,324 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:52,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:52,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 04:13:52,363 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-14 04:13:52,429 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-14 04:13:52,447 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:52,448 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:52,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:52,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,468 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 04:13:52,469 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:52,470 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:52,471 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:52,472 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 04:13:52,556 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1126921996/.staging/job_local1126921996_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,557 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1126921996/.staging/job_local1126921996_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,608 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1126921996_0009/job_local1126921996_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,609 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1126921996_0009/job_local1126921996_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1126921996_0009
2015-08-14 04:13:52,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:52,619 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:52,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:52,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:52,637 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,637 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 04:13:52,667 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-14 04:13:52,732 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 04:13:52,750 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:52,751 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:52,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:52,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 04:13:52,773 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:52,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:52,775 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:52,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 04:13:52,864 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1554566234/.staging/job_local1554566234_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,865 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1554566234/.staging/job_local1554566234_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,928 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1554566234_0010/job_local1554566234_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:52,928 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1554566234_0010/job_local1554566234_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:52,930 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1554566234_0010
2015-08-14 04:13:52,930 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:52,938 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:52,948 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:52,949 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:52,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:52,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 04:13:52,961 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:52,972 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:52,973 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:52,976 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1554566234_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:52,981 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1554566234_0010 state at FAILED
2015-08-14 04:13:52,982 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:52,983 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:52,983 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:52,984 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:52,984 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 04:13:52,985 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:52,985 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-14 04:13:52,986 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-08-14 04:13:53,008 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,010 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,019 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-14 04:13:53,038 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,038 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:53,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 04:13:53,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:53,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:53,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:53,058 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 04:13:53,141 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity957293415/.staging/job_local957293415_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,141 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity957293415/.staging/job_local957293415_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,191 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local957293415_0011/job_local957293415_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,191 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local957293415_0011/job_local957293415_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local957293415_0011
2015-08-14 04:13:53,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:53,201 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:53,211 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:53,211 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:53,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,220 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 04:13:53,221 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,222 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,222 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,225 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local957293415_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local957293415_0011 state at FAILED
2015-08-14 04:13:53,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:53,236 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:53,236 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:53,237 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:53,237 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 04:13:53,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:53,238 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-14 04:13:53,239 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-14 04:13:53,257 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,257 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:53,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 04:13:53,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:53,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:53,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:53,274 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 04:13:53,354 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1602975377/.staging/job_local1602975377_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,354 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1602975377/.staging/job_local1602975377_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,403 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1602975377_0012/job_local1602975377_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,403 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1602975377_0012/job_local1602975377_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,404 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1602975377_0012
2015-08-14 04:13:53,405 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:53,411 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:53,421 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:53,422 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:53,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 04:13:53,431 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,432 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,433 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,435 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1602975377_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:53,436 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1602975377_0012 state at FAILED
2015-08-14 04:13:53,436 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:53,437 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:53,437 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:53,437 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:53,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 04:13:53,438 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:53,438 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-14 04:13:53,439 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-14 04:13:53,456 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,457 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,463 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-14 04:13:53,489 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,490 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:53,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 04:13:53,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:53,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:53,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:53,507 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-14 04:13:53,593 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity149963211/.staging/job_local149963211_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,594 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity149963211/.staging/job_local149963211_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,641 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local149963211_0013/job_local149963211_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,642 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local149963211_0013/job_local149963211_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local149963211_0013
2015-08-14 04:13:53,643 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:53,650 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:53,660 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:53,660 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:53,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 04:13:53,699 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-14 04:13:53,761 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-14 04:13:53,781 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,781 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,787 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-14 04:13:53,806 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:53,806 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:53,822 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:53,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 04:13:53,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:53,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:53,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:53,824 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-14 04:13:53,903 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1717597433/.staging/job_local1717597433_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,903 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1717597433/.staging/job_local1717597433_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,950 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1717597433_0014/job_local1717597433_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:53,951 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1717597433_0014/job_local1717597433_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:53,952 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1717597433_0014
2015-08-14 04:13:53,952 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:53,959 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:53,968 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:53,968 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:53,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:53,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 04:13:54,011 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-14 04:13:54,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-08-14 04:13:54,092 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:54,093 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:54,111 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:54,112 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,112 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 04:13:54,113 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:54,113 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:54,113 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:54,114 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-14 04:13:54,194 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity393206227/.staging/job_local393206227_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,194 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity393206227/.staging/job_local393206227_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,241 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local393206227_0015/job_local393206227_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,242 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local393206227_0015/job_local393206227_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,243 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local393206227_0015
2015-08-14 04:13:54,243 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:54,249 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:54,258 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:54,258 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:54,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,267 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 04:13:54,298 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-14 04:13:54,360 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-14 04:13:54,377 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:54,378 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:54,391 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:54,392 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 04:13:54,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:54,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:54,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:54,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-14 04:13:54,472 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1716415498/.staging/job_local1716415498_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,473 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1716415498/.staging/job_local1716415498_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,519 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1716415498_0016/job_local1716415498_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,520 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1716415498_0016/job_local1716415498_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,521 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1716415498_0016
2015-08-14 04:13:54,522 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:54,531 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:54,545 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:54,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:54,555 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,556 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 04:13:54,578 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-14 04:13:54,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-14 04:13:54,658 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:54,658 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:54,672 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:54,673 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-14 04:13:54,751 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity9699484/.staging/job_local9699484_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,752 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity9699484/.staging/job_local9699484_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,800 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local9699484_0017/job_local9699484_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:54,800 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local9699484_0017/job_local9699484_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:54,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local9699484_0017
2015-08-14 04:13:54,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:54,808 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:54,816 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:54,816 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:54,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 04:13:54,846 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-14 04:13:54,907 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-08-14 04:13:54,924 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:54,924 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:54,937 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:54,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:54,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 04:13:54,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:54,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:54,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:54,939 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-14 04:13:55,014 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1409794285/.staging/job_local1409794285_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,014 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1409794285/.staging/job_local1409794285_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,060 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1409794285_0018/job_local1409794285_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,060 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1409794285_0018/job_local1409794285_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,061 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1409794285_0018
2015-08-14 04:13:55,065 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:55,072 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:55,080 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:55,080 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:55,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,090 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 04:13:55,120 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-14 04:13:55,182 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-14 04:13:55,201 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,201 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-14 04:13:55,225 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,226 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,242 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:55,242 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,243 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 04:13:55,243 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:55,244 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:55,244 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:55,245 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-14 04:13:55,320 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1527079036/.staging/job_local1527079036_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,321 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1527079036/.staging/job_local1527079036_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,367 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1527079036_0019/job_local1527079036_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,367 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1527079036_0019/job_local1527079036_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1527079036_0019
2015-08-14 04:13:55,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:55,374 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:55,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:55,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:55,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 04:13:55,414 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-14 04:13:55,474 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-14 04:13:55,491 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,492 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:55,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 04:13:55,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:55,507 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:55,508 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:55,510 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-14 04:13:55,587 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1567305947/.staging/job_local1567305947_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,587 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1567305947/.staging/job_local1567305947_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,637 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1567305947_0020/job_local1567305947_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,638 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1567305947_0020/job_local1567305947_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,639 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1567305947_0020
2015-08-14 04:13:55,639 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:55,646 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:55,654 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:55,654 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:55,661 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,661 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 04:13:55,684 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-14 04:13:55,744 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-14 04:13:55,762 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,763 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:55,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,775 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 04:13:55,775 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:55,775 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:55,776 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:55,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 04:13:55,851 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity753131804/.staging/job_local753131804_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,851 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity753131804/.staging/job_local753131804_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,897 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local753131804_0021/job_local753131804_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:55,898 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local753131804_0021/job_local753131804_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:55,899 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local753131804_0021
2015-08-14 04:13:55,900 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:55,905 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:55,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:55,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:55,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 04:13:55,921 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:55,922 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:55,923 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:55,925 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local753131804_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:55,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local753131804_0021 state at FAILED
2015-08-14 04:13:55,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:55,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:55,934 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:55,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:55,936 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 04:13:55,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:55,937 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-14 04:13:55,937 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-08-14 04:13:55,954 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,954 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,958 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-14 04:13:55,975 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:55,975 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:55,986 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:55,986 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:55,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 04:13:55,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:55,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:55,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:55,988 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 04:13:56,069 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity106731316/.staging/job_local106731316_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,070 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity106731316/.staging/job_local106731316_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,119 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local106731316_0022/job_local106731316_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,119 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local106731316_0022/job_local106731316_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,121 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local106731316_0022
2015-08-14 04:13:56,121 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:56,127 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:56,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:56,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:56,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,143 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 04:13:56,144 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,145 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,145 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,147 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local106731316_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,152 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local106731316_0022 state at FAILED
2015-08-14 04:13:56,152 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:56,153 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:56,153 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:56,153 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:56,155 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 04:13:56,156 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:56,157 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-14 04:13:56,157 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-14 04:13:56,174 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,174 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,185 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:56,186 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,186 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 04:13:56,186 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:56,187 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:56,187 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:56,188 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 04:13:56,263 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity806828898/.staging/job_local806828898_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,263 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity806828898/.staging/job_local806828898_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,309 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local806828898_0023/job_local806828898_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,309 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local806828898_0023/job_local806828898_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local806828898_0023
2015-08-14 04:13:56,311 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:56,317 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:56,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:56,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:56,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 04:13:56,333 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,334 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,335 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,339 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local806828898_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 04:13:56,342 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local806828898_0023 state at FAILED
2015-08-14 04:13:56,342 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-14 04:13:56,342 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-14 04:13:56,342 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-14 04:13:56,343 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-14 04:13:56,343 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 04:13:56,344 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-14 04:13:56,344 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-14 04:13:56,345 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-08-14 04:13:56,361 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,362 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,371 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:56,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 04:13:56,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:56,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:56,372 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:56,373 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-14 04:13:56,450 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity588136352/.staging/job_local588136352_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,450 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity588136352/.staging/job_local588136352_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,502 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local588136352_0024/job_local588136352_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,503 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local588136352_0024/job_local588136352_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,504 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local588136352_0024
2015-08-14 04:13:56,504 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:56,511 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:56,519 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:56,519 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:56,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,527 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 04:13:56,554 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-14 04:13:56,614 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-08-14 04:13:56,631 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,631 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,635 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-14 04:13:56,652 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,653 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,663 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:56,664 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,664 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 04:13:56,665 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:56,665 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:56,666 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:56,667 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-14 04:13:56,741 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity94515270/.staging/job_local94515270_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,741 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity94515270/.staging/job_local94515270_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,790 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local94515270_0025/job_local94515270_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:56,790 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local94515270_0025/job_local94515270_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:56,791 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local94515270_0025
2015-08-14 04:13:56,792 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:56,797 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:56,805 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:56,806 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:56,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,814 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 04:13:56,838 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-14 04:13:56,897 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-14 04:13:56,916 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,916 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,921 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-08-14 04:13:56,944 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:56,944 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:56,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:56,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:56,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 04:13:56,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:56,957 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:56,957 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:56,958 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-14 04:13:57,033 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998920617/.staging/job_local998920617_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,033 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998920617/.staging/job_local998920617_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,082 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998920617_0026/job_local998920617_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,082 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998920617_0026/job_local998920617_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,084 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local998920617_0026
2015-08-14 04:13:57,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:57,090 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:57,098 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:57,099 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:57,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 04:13:57,129 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-14 04:13:57,188 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-14 04:13:57,205 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:57,206 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:57,216 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:57,216 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 04:13:57,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:57,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:57,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:57,217 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-14 04:13:57,291 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1856222590/.staging/job_local1856222590_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,292 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1856222590/.staging/job_local1856222590_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,343 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1856222590_0027/job_local1856222590_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,343 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1856222590_0027/job_local1856222590_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,344 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1856222590_0027
2015-08-14 04:13:57,344 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:57,350 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:57,359 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:57,359 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:57,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 04:13:57,389 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-14 04:13:57,449 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-14 04:13:57,465 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:57,465 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:57,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:57,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 04:13:57,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:57,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:57,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:57,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-14 04:13:57,551 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity467684797/.staging/job_local467684797_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,551 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity467684797/.staging/job_local467684797_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,600 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local467684797_0028/job_local467684797_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,601 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local467684797_0028/job_local467684797_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,602 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local467684797_0028
2015-08-14 04:13:57,602 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:57,608 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:57,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:57,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:57,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 04:13:57,649 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-14 04:13:57,708 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-14 04:13:57,724 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:57,725 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:57,735 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:57,735 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,735 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 04:13:57,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:57,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:57,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:57,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-14 04:13:57,816 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1599190404/.staging/job_local1599190404_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,817 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1599190404/.staging/job_local1599190404_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,864 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1599190404_0029/job_local1599190404_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:57,864 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1599190404_0029/job_local1599190404_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:57,866 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1599190404_0029
2015-08-14 04:13:57,866 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:57,872 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:57,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:57,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:57,886 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,886 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 04:13:57,911 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-14 04:13:57,969 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-14 04:13:57,985 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:57,985 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:57,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:57,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:57,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 04:13:57,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:57,996 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:57,996 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:57,996 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-14 04:13:58,069 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity592890439/.staging/job_local592890439_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:58,069 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity592890439/.staging/job_local592890439_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:58,116 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local592890439_0030/job_local592890439_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:58,116 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local592890439_0030/job_local592890439_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:58,117 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local592890439_0030
2015-08-14 04:13:58,118 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:58,124 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:58,132 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:58,132 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:58,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:58,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 04:13:58,162 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-14 04:13:58,221 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-14 04:13:58,236 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:58,237 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-14 04:13:58,248 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-14 04:13:58,249 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 04:13:58,323 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity641568366/.staging/job_local641568366_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:58,323 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity641568366/.staging/job_local641568366_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:58,369 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local641568366_0031/job_local641568366_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 04:13:58,369 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local641568366_0031/job_local641568366_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 04:13:58,371 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local641568366_0031
2015-08-14 04:13:58,371 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-14 04:13:58,376 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt
2015-08-14 04:13:58,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:13:58,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:13:58,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/nums.20.txt"]
2015-08-14 04:13:58,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 04:13:58,416 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-14 04:13:58,474 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 04:13:58,490 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:13:58,490 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:13:58,494 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'