2016-05-18 05:52:37,647 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:52:37,677 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-05-18 05:52:38,235 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-18 05:52:38,788 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 05:52:38,941 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:52:39,050 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:39,053 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:39,164 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4C06591E073343D69E3660A474C78406
2016-05-18 05:52:39,308 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-05-18 05:52:39,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:39,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:39,456 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 05:52:39,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:39,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:39,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 05:52:39,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:39,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:39,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:39,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-18 05:52:39,972 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1852218224/.staging/job_local1852218224_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:39,980 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1852218224/.staging/job_local1852218224_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:40,073 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1852218224_0001/job_local1852218224_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:40,078 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1852218224_0001/job_local1852218224_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:40,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1852218224_0001
2016-05-18 05:52:40,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:40,154 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:40,174 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:40,175 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:40,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0C434DDEBF949F0B98943926176A839, ordinal: 0
2016-05-18 05:52:40,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:40,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 05:52:40,253 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0C434DDEBF949F0B98943926176A839, mem on start (mb), free: 180, total: 223, max: 672
2016-05-18 05:52:40,269 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0C434DDEBF949F0B98943926176A839, mem on close (mb), free: 179, total: 223, max: 672
2016-05-18 05:52:40,315 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-18 05:52:40,316 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.856
2016-05-18 05:52:40,401 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-18 05:52:40,429 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:40,430 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:40,493 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 05:52:40,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:40,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:40,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:40,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:40,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 05:52:40,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:40,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:40,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:40,514 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-18 05:52:40,618 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1339737088/.staging/job_local1339737088_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:40,620 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1339737088/.staging/job_local1339737088_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:40,695 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1339737088_0002/job_local1339737088_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:40,698 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1339737088_0002/job_local1339737088_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:40,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1339737088_0002
2016-05-18 05:52:40,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:40,708 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:40,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:40,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:40,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDFDBEE4D75C425E9B36A47CA043CACF, ordinal: 0
2016-05-18 05:52:40,731 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:40,731 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 05:52:40,731 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDFDBEE4D75C425E9B36A47CA043CACF, mem on start (mb), free: 250, total: 281, max: 672
2016-05-18 05:52:40,734 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDFDBEE4D75C425E9B36A47CA043CACF, mem on close (mb), free: 250, total: 281, max: 672
2016-05-18 05:52:40,756 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-18 05:52:40,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.243
2016-05-18 05:52:40,846 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-18 05:52:40,877 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:40,878 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:40,939 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-05-18 05:52:40,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:40,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:40,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:40,956 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:40,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 05:52:40,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:40,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:40,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:40,960 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-18 05:52:41,148 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1598343574/.staging/job_local1598343574_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,149 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1598343574/.staging/job_local1598343574_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,214 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1598343574_0003/job_local1598343574_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,216 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1598343574_0003/job_local1598343574_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1598343574_0003
2016-05-18 05:52:41,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:41,228 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:41,242 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:41,243 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:41,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DAD5E907DDE948E883FA9A2C399DFC12, ordinal: 0
2016-05-18 05:52:41,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:41,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 05:52:41,256 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD5E907DDE948E883FA9A2C399DFC12, mem on start (mb), free: 198, total: 281, max: 672
2016-05-18 05:52:41,259 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAD5E907DDE948E883FA9A2C399DFC12, mem on close (mb), free: 198, total: 281, max: 672
2016-05-18 05:52:41,284 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-18 05:52:41,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.328
2016-05-18 05:52:41,352 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-18 05:52:41,371 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:41,371 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:41,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 05:52:41,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:41,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:41,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:41,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:41,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 05:52:41,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:41,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:41,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:41,429 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-18 05:52:41,508 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1657470415/.staging/job_local1657470415_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,509 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1657470415/.staging/job_local1657470415_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,582 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1657470415_0004/job_local1657470415_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,583 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1657470415_0004/job_local1657470415_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1657470415_0004
2016-05-18 05:52:41,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:41,591 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:41,602 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:41,602 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:41,617 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB3BD926AB9943CD8799D0AAFC97A3A4, ordinal: 0
2016-05-18 05:52:41,618 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:41,618 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 05:52:41,618 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB3BD926AB9943CD8799D0AAFC97A3A4, mem on start (mb), free: 264, total: 281, max: 672
2016-05-18 05:52:41,621 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB3BD926AB9943CD8799D0AAFC97A3A4, mem on close (mb), free: 264, total: 281, max: 672
2016-05-18 05:52:41,640 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-18 05:52:41,641 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.213
2016-05-18 05:52:41,693 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-18 05:52:41,707 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:41,708 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:41,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 05:52:41,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:41,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:41,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:41,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:41,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 05:52:41,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:41,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:41,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:41,758 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-18 05:52:41,831 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity83770914/.staging/job_local83770914_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,832 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity83770914/.staging/job_local83770914_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,870 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local83770914_0005/job_local83770914_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:41,870 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local83770914_0005/job_local83770914_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:41,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local83770914_0005
2016-05-18 05:52:41,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:41,879 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:41,887 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:41,888 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:41,898 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A314959F45474CF2ACF7618189619D8A, ordinal: 0
2016-05-18 05:52:41,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:41,900 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 05:52:41,900 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A314959F45474CF2ACF7618189619D8A, mem on start (mb), free: 212, total: 281, max: 672
2016-05-18 05:52:41,903 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A314959F45474CF2ACF7618189619D8A, mem on close (mb), free: 212, total: 281, max: 672
2016-05-18 05:52:41,927 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-18 05:52:41,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.170
2016-05-18 05:52:41,976 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-18 05:52:41,990 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:41,991 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:42,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:52:42,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:42,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:42,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:42,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 05:52:42,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:42,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:42,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:42,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-18 05:52:42,106 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity529267848/.staging/job_local529267848_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,107 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity529267848/.staging/job_local529267848_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,156 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local529267848_0006/job_local529267848_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,157 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local529267848_0006/job_local529267848_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local529267848_0006
2016-05-18 05:52:42,159 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:42,164 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:42,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:42,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:42,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DE052C4425CC4BDCB4B868ED8A5C4B77, ordinal: 0
2016-05-18 05:52:42,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 05:52:42,185 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE052C4425CC4BDCB4B868ED8A5C4B77, mem on start (mb), free: 162, total: 281, max: 672
2016-05-18 05:52:42,188 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE052C4425CC4BDCB4B868ED8A5C4B77, mem on close (mb), free: 162, total: 281, max: 672
2016-05-18 05:52:42,205 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-18 05:52:42,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.166
2016-05-18 05:52:42,274 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-18 05:52:42,290 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:42,290 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:42,308 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-05-18 05:52:42,309 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:42,309 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-18 05:52:42,324 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:42,325 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:42,356 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:52:42,357 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:42,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:42,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:42,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 05:52:42,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:42,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:42,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:42,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-18 05:52:42,431 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity249165017/.staging/job_local249165017_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,433 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity249165017/.staging/job_local249165017_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,470 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local249165017_0007/job_local249165017_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,471 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local249165017_0007/job_local249165017_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local249165017_0007
2016-05-18 05:52:42,472 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:42,477 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:42,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:42,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:42,493 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8265C9059034965870E27AE19FB8BAA, ordinal: 0
2016-05-18 05:52:42,494 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 05:52:42,495 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8265C9059034965870E27AE19FB8BAA, mem on start (mb), free: 330, total: 395, max: 672
2016-05-18 05:52:42,498 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8265C9059034965870E27AE19FB8BAA, mem on close (mb), free: 330, total: 395, max: 672
2016-05-18 05:52:42,518 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-18 05:52:42,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.148
2016-05-18 05:52:42,561 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-18 05:52:42,575 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:42,575 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:42,609 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 05:52:42,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:42,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:42,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:42,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 05:52:42,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:42,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:42,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:42,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-18 05:52:42,688 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity380718328/.staging/job_local380718328_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,689 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity380718328/.staging/job_local380718328_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,725 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local380718328_0008/job_local380718328_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,726 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local380718328_0008/job_local380718328_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:42,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local380718328_0008
2016-05-18 05:52:42,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:42,731 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:42,739 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:42,739 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:42,747 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A3FAC834A18349F386A7E1617390B55B, ordinal: 0
2016-05-18 05:52:42,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,748 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 05:52:42,749 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3FAC834A18349F386A7E1617390B55B, mem on start (mb), free: 268, total: 395, max: 672
2016-05-18 05:52:42,752 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A3FAC834A18349F386A7E1617390B55B, mem on close (mb), free: 268, total: 395, max: 672
2016-05-18 05:52:42,771 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-18 05:52:42,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.150
2016-05-18 05:52:42,818 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-18 05:52:42,833 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:42,834 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:42,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:52:42,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:42,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:42,880 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:42,880 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:42,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 05:52:42,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:42,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:42,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:42,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 05:52:42,959 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1935434592/.staging/job_local1935434592_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:42,961 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1935434592/.staging/job_local1935434592_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,010 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1935434592_0009/job_local1935434592_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,011 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1935434592_0009/job_local1935434592_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1935434592_0009
2016-05-18 05:52:43,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:43,019 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:43,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:43,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:43,037 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA26B9C20C184B2EB3CA075216954628, ordinal: 0
2016-05-18 05:52:43,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 05:52:43,039 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA26B9C20C184B2EB3CA075216954628, mem on start (mb), free: 207, total: 395, max: 672
2016-05-18 05:52:43,042 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA26B9C20C184B2EB3CA075216954628, mem on close (mb), free: 207, total: 395, max: 672
2016-05-18 05:52:43,056 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-18 05:52:43,057 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.176
2016-05-18 05:52:43,115 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 05:52:43,131 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,132 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:52:43,165 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:43,165 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:43,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:43,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,176 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 05:52:43,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:43,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:43,177 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:43,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 05:52:43,250 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2076207013/.staging/job_local2076207013_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,251 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2076207013/.staging/job_local2076207013_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,320 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2076207013_0010/job_local2076207013_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,321 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2076207013_0010/job_local2076207013_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2076207013_0010
2016-05-18 05:52:43,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:43,327 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:43,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:43,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:43,345 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AD8E618F7D694CFBB7FBA304EA3BE8C9, ordinal: 0
2016-05-18 05:52:43,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 05:52:43,346 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD8E618F7D694CFBB7FBA304EA3BE8C9, mem on start (mb), free: 370, total: 391, max: 672
2016-05-18 05:52:43,348 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,351 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,352 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,353 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD8E618F7D694CFBB7FBA304EA3BE8C9, mem on close (mb), free: 369, total: 391, max: 672
2016-05-18 05:52:43,355 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2076207013_0010
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,364 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local2076207013_0010 state at FAILED
2016-05-18 05:52:43,364 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:43,365 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:43,365 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:43,365 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:43,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 05:52:43,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:43,368 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-18 05:52:43,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.191
2016-05-18 05:52:43,368 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-18 05:52:43,382 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,382 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.018
2016-05-18 05:52:43,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:43,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-18 05:52:43,421 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,421 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 05:52:43,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:43,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:43,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:43,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 05:52:43,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:43,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:43,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:43,465 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 05:52:43,521 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity618021327/.staging/job_local618021327_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,521 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity618021327/.staging/job_local618021327_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,557 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local618021327_0011/job_local618021327_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,558 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local618021327_0011/job_local618021327_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local618021327_0011
2016-05-18 05:52:43,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:43,564 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:43,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:43,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:43,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EDDDC41A88A74C1298571FCC85CF4E78, ordinal: 0
2016-05-18 05:52:43,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 05:52:43,590 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDDDC41A88A74C1298571FCC85CF4E78, mem on start (mb), free: 316, total: 391, max: 672
2016-05-18 05:52:43,592 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,596 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,600 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,603 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDDDC41A88A74C1298571FCC85CF4E78, mem on close (mb), free: 316, total: 391, max: 672
2016-05-18 05:52:43,604 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local618021327_0011
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,611 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local618021327_0011 state at FAILED
2016-05-18 05:52:43,611 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:43,611 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:43,611 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:43,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:43,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 05:52:43,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:43,613 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-18 05:52:43,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.151
2016-05-18 05:52:43,613 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-18 05:52:43,628 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,628 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 05:52:43,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:43,664 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:43,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:43,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 05:52:43,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:43,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:43,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:43,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 05:52:43,733 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1187587575/.staging/job_local1187587575_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,734 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1187587575/.staging/job_local1187587575_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,772 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1187587575_0012/job_local1187587575_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,773 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1187587575_0012/job_local1187587575_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:43,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1187587575_0012
2016-05-18 05:52:43,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:43,778 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:43,788 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:43,789 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:43,799 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFCDC7D873B74C148904FA1F2963D338, ordinal: 0
2016-05-18 05:52:43,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,801 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 05:52:43,801 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFCDC7D873B74C148904FA1F2963D338, mem on start (mb), free: 267, total: 391, max: 672
2016-05-18 05:52:43,802 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,806 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,811 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,813 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFCDC7D873B74C148904FA1F2963D338, mem on close (mb), free: 267, total: 391, max: 672
2016-05-18 05:52:43,815 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1187587575_0012
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:43,815 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1187587575_0012 state at FAILED
2016-05-18 05:52:43,816 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:43,816 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:43,816 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:43,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:43,817 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 05:52:43,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:43,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-18 05:52:43,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.145
2016-05-18 05:52:43,819 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-18 05:52:43,835 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,836 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2016-05-18 05:52:43,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:43,850 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-18 05:52:43,862 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:43,862 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:43,893 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 05:52:43,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:43,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:43,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:43,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:43,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 05:52:43,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:43,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:43,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:43,904 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-18 05:52:43,976 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity429106358/.staging/job_local429106358_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:43,977 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity429106358/.staging/job_local429106358_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,017 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local429106358_0013/job_local429106358_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,018 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local429106358_0013/job_local429106358_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local429106358_0013
2016-05-18 05:52:44,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:44,023 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:44,031 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:44,032 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:44,041 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CBC91589B6FB4269B137E13CF314B7D9, ordinal: 0
2016-05-18 05:52:44,041 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,042 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 05:52:44,042 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBC91589B6FB4269B137E13CF314B7D9, mem on start (mb), free: 215, total: 391, max: 672
2016-05-18 05:52:44,044 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBC91589B6FB4269B137E13CF314B7D9, mem on close (mb), free: 215, total: 391, max: 672
2016-05-18 05:52:44,064 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-18 05:52:44,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.161
2016-05-18 05:52:44,109 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-18 05:52:44,125 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:44,126 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:44,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 05:52:44,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:44,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-18 05:52:44,161 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:44,161 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:44,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 05:52:44,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:44,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:44,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:44,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 05:52:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-18 05:52:44,275 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity136960962/.staging/job_local136960962_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,276 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity136960962/.staging/job_local136960962_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,314 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local136960962_0014/job_local136960962_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,315 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local136960962_0014/job_local136960962_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local136960962_0014
2016-05-18 05:52:44,315 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:44,320 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:44,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:44,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:44,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA642DDCB1F94B4A8D3607E228A195FC, ordinal: 0
2016-05-18 05:52:44,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 05:52:44,334 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA642DDCB1F94B4A8D3607E228A195FC, mem on start (mb), free: 151, total: 391, max: 672
2016-05-18 05:52:44,337 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA642DDCB1F94B4A8D3607E228A195FC, mem on close (mb), free: 151, total: 391, max: 672
2016-05-18 05:52:44,368 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-18 05:52:44,369 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.158
2016-05-18 05:52:44,412 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-18 05:52:44,424 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:44,424 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:52:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:44,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 05:52:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-18 05:52:44,523 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1996517146/.staging/job_local1996517146_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,524 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1996517146/.staging/job_local1996517146_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,556 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1996517146_0015/job_local1996517146_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,557 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1996517146_0015/job_local1996517146_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,558 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1996517146_0015
2016-05-18 05:52:44,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:44,563 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:44,569 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:44,569 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:44,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF206C8FD9CF433DA4E43871D64F25CD, ordinal: 0
2016-05-18 05:52:44,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 05:52:44,577 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF206C8FD9CF433DA4E43871D64F25CD, mem on start (mb), free: 322, total: 394, max: 672
2016-05-18 05:52:44,579 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF206C8FD9CF433DA4E43871D64F25CD, mem on close (mb), free: 322, total: 394, max: 672
2016-05-18 05:52:44,593 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-18 05:52:44,593 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.126
2016-05-18 05:52:44,637 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-18 05:52:44,648 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:44,648 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:44,675 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:52:44,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:44,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:44,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:44,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 05:52:44,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:44,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:44,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:44,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-18 05:52:44,771 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1271833920/.staging/job_local1271833920_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,773 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1271833920/.staging/job_local1271833920_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,823 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1271833920_0016/job_local1271833920_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:44,824 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1271833920_0016/job_local1271833920_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:44,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1271833920_0016
2016-05-18 05:52:44,825 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:44,831 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:44,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:44,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:44,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD38EB0379834590B304A2937A127A9A, ordinal: 0
2016-05-18 05:52:44,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:44,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 05:52:44,845 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD38EB0379834590B304A2937A127A9A, mem on start (mb), free: 261, total: 394, max: 672
2016-05-18 05:52:44,848 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD38EB0379834590B304A2937A127A9A, mem on close (mb), free: 261, total: 394, max: 672
2016-05-18 05:52:44,870 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-18 05:52:44,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.180
2016-05-18 05:52:44,932 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-18 05:52:44,953 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:44,953 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:44,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:52:44,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:44,989 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:45,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:45,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 05:52:45,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:45,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:45,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:45,004 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-18 05:52:45,064 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1213195541/.staging/job_local1213195541_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,066 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1213195541/.staging/job_local1213195541_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,102 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1213195541_0017/job_local1213195541_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,103 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1213195541_0017/job_local1213195541_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1213195541_0017
2016-05-18 05:52:45,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:45,109 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:45,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:45,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:45,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C748B3A8E11C4C179BA3F902CD8A5387, ordinal: 0
2016-05-18 05:52:45,124 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,124 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 05:52:45,124 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C748B3A8E11C4C179BA3F902CD8A5387, mem on start (mb), free: 202, total: 394, max: 672
2016-05-18 05:52:45,128 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C748B3A8E11C4C179BA3F902CD8A5387, mem on close (mb), free: 202, total: 394, max: 672
2016-05-18 05:52:45,147 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-18 05:52:45,148 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.144
2016-05-18 05:52:45,188 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-18 05:52:45,202 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:45,203 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:45,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 05:52:45,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:45,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:45,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:45,239 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 05:52:45,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:45,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:45,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:45,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-18 05:52:45,295 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1737046282/.staging/job_local1737046282_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,296 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1737046282/.staging/job_local1737046282_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,334 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1737046282_0018/job_local1737046282_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,335 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1737046282_0018/job_local1737046282_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1737046282_0018
2016-05-18 05:52:45,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:45,340 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:45,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:45,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:45,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDC2B41B0E4B4DA093126998896E198C, ordinal: 0
2016-05-18 05:52:45,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 05:52:45,355 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDC2B41B0E4B4DA093126998896E198C, mem on start (mb), free: 370, total: 395, max: 672
2016-05-18 05:52:45,358 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDC2B41B0E4B4DA093126998896E198C, mem on close (mb), free: 370, total: 395, max: 672
2016-05-18 05:52:45,369 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-18 05:52:45,370 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.130
2016-05-18 05:52:45,417 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-18 05:52:45,429 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:45,430 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:45,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 05:52:45,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:45,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-18 05:52:45,454 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:45,454 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:52:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:45,483 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 05:52:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:45,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:45,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:45,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-18 05:52:45,536 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity381292704/.staging/job_local381292704_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,537 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity381292704/.staging/job_local381292704_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,571 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local381292704_0019/job_local381292704_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,572 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local381292704_0019/job_local381292704_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local381292704_0019
2016-05-18 05:52:45,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:45,577 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:45,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:45,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:45,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2E35CDC0B714BFBBC69AF2F1E20C2EF, ordinal: 0
2016-05-18 05:52:45,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 05:52:45,592 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2E35CDC0B714BFBBC69AF2F1E20C2EF, mem on start (mb), free: 304, total: 395, max: 672
2016-05-18 05:52:45,594 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2E35CDC0B714BFBBC69AF2F1E20C2EF, mem on close (mb), free: 304, total: 395, max: 672
2016-05-18 05:52:45,607 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-18 05:52:45,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.123
2016-05-18 05:52:45,651 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-18 05:52:45,664 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:45,664 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:45,683 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 05:52:45,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:45,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:45,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 05:52:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:45,695 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-18 05:52:45,747 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1980988648/.staging/job_local1980988648_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,747 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1980988648/.staging/job_local1980988648_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,782 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1980988648_0020/job_local1980988648_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,783 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1980988648_0020/job_local1980988648_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1980988648_0020
2016-05-18 05:52:45,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:45,787 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:45,793 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:45,793 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:45,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C545BF21741244E281E38E0F451B5EA6, ordinal: 0
2016-05-18 05:52:45,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,801 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 05:52:45,801 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C545BF21741244E281E38E0F451B5EA6, mem on start (mb), free: 244, total: 395, max: 672
2016-05-18 05:52:45,804 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C545BF21741244E281E38E0F451B5EA6, mem on close (mb), free: 244, total: 395, max: 672
2016-05-18 05:52:45,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-18 05:52:45,818 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.126
2016-05-18 05:52:45,858 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-18 05:52:45,869 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:45,869 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:45,887 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 05:52:45,888 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:45,888 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:45,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:45,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:45,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 05:52:45,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:45,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:45,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:45,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 05:52:45,955 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity634684921/.staging/job_local634684921_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,956 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity634684921/.staging/job_local634684921_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,989 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local634684921_0021/job_local634684921_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:45,990 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local634684921_0021/job_local634684921_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:45,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local634684921_0021
2016-05-18 05:52:45,991 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:45,996 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:46,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:46,003 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:46,013 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5411CFB79BD42BAAEBD6EEFCC30DFE2, ordinal: 0
2016-05-18 05:52:46,013 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 05:52:46,014 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5411CFB79BD42BAAEBD6EEFCC30DFE2, mem on start (mb), free: 184, total: 395, max: 672
2016-05-18 05:52:46,015 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,021 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,027 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,033 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5411CFB79BD42BAAEBD6EEFCC30DFE2, mem on close (mb), free: 184, total: 395, max: 672
2016-05-18 05:52:46,034 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local634684921_0021
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,044 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local634684921_0021 state at FAILED
2016-05-18 05:52:46,044 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:46,044 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:46,045 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:46,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:46,045 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 05:52:46,046 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:46,046 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-18 05:52:46,046 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.150
2016-05-18 05:52:46,047 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-18 05:52:46,059 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,060 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 05:52:46,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:46,071 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-18 05:52:46,086 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,086 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:52:46,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:46,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:46,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:46,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 05:52:46,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:46,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:46,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:46,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 05:52:46,185 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2033911635/.staging/job_local2033911635_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,186 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2033911635/.staging/job_local2033911635_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,223 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2033911635_0022/job_local2033911635_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,225 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2033911635_0022/job_local2033911635_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2033911635_0022
2016-05-18 05:52:46,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:46,231 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:46,236 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:46,236 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:46,242 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE2665724F6B426DB757026D66B080A0, ordinal: 0
2016-05-18 05:52:46,243 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,243 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 05:52:46,243 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE2665724F6B426DB757026D66B080A0, mem on start (mb), free: 344, total: 379, max: 672
2016-05-18 05:52:46,244 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,247 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,251 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,254 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE2665724F6B426DB757026D66B080A0, mem on close (mb), free: 343, total: 379, max: 672
2016-05-18 05:52:46,255 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2033911635_0022
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,259 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local2033911635_0022 state at FAILED
2016-05-18 05:52:46,259 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:46,259 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:46,259 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:46,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:46,260 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 05:52:46,261 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:46,261 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-18 05:52:46,261 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.140
2016-05-18 05:52:46,262 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-18 05:52:46,277 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,278 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:52:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:46,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:46,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:46,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 05:52:46,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:46,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:46,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:46,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 05:52:46,366 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1537449116/.staging/job_local1537449116_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,367 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1537449116/.staging/job_local1537449116_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,397 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1537449116_0023/job_local1537449116_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,398 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1537449116_0023/job_local1537449116_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,399 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1537449116_0023
2016-05-18 05:52:46,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:46,404 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:46,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:46,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:46,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D015DA3B21A64EC59412E1354BE4E4C3, ordinal: 0
2016-05-18 05:52:46,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 05:52:46,417 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D015DA3B21A64EC59412E1354BE4E4C3, mem on start (mb), free: 295, total: 379, max: 672
2016-05-18 05:52:46,419 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,426 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,431 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,435 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D015DA3B21A64EC59412E1354BE4E4C3, mem on close (mb), free: 294, total: 379, max: 672
2016-05-18 05:52:46,436 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1537449116_0023
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
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.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:52:46,442 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1537449116_0023 state at FAILED
2016-05-18 05:52:46,442 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:52:46,442 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:52:46,442 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:52:46,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:52:46,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 05:52:46,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:52:46,444 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-18 05:52:46,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.134
2016-05-18 05:52:46,445 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-18 05:52:46,458 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,458 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,475 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:52:46,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:46,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:46,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:46,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 05:52:46,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:46,487 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:46,487 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:46,488 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-18 05:52:46,540 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity87503349/.staging/job_local87503349_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,541 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity87503349/.staging/job_local87503349_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,572 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local87503349_0024/job_local87503349_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,573 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local87503349_0024/job_local87503349_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local87503349_0024
2016-05-18 05:52:46,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:46,578 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:46,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:46,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:46,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BFFE2D10D4CE4FA68097D9E57F860442, ordinal: 0
2016-05-18 05:52:46,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 05:52:46,592 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFFE2D10D4CE4FA68097D9E57F860442, mem on start (mb), free: 247, total: 379, max: 672
2016-05-18 05:52:46,596 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFFE2D10D4CE4FA68097D9E57F860442, mem on close (mb), free: 247, total: 379, max: 672
2016-05-18 05:52:46,618 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-18 05:52:46,618 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.132
2016-05-18 05:52:46,665 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-18 05:52:46,680 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,681 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 05:52:46,691 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:46,691 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-18 05:52:46,703 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,704 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:52:46,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:46,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:46,735 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-18 05:52:46,786 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1828190625/.staging/job_local1828190625_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,787 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1828190625/.staging/job_local1828190625_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,818 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1828190625_0025/job_local1828190625_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:46,819 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1828190625_0025/job_local1828190625_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:46,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1828190625_0025
2016-05-18 05:52:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:46,824 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:46,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:46,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:46,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF8D95DDC6204D09AC58815B055406E2, ordinal: 0
2016-05-18 05:52:46,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 05:52:46,837 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF8D95DDC6204D09AC58815B055406E2, mem on start (mb), free: 182, total: 379, max: 672
2016-05-18 05:52:46,839 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF8D95DDC6204D09AC58815B055406E2, mem on close (mb), free: 182, total: 379, max: 672
2016-05-18 05:52:46,855 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-18 05:52:46,855 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.122
2016-05-18 05:52:46,896 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-18 05:52:46,908 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,908 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.005
2016-05-18 05:52:46,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:46,917 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-18 05:52:46,927 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:46,927 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:46,943 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 05:52:46,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:46,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:46,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:46,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:46,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 05:52:46,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:46,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:46,953 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:46,953 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-18 05:52:47,023 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity690761727/.staging/job_local690761727_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,024 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity690761727/.staging/job_local690761727_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,057 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local690761727_0026/job_local690761727_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,058 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local690761727_0026/job_local690761727_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local690761727_0026
2016-05-18 05:52:47,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:47,064 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:47,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:47,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:47,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C2A3F8E984214467BF842C4B96FAB623, ordinal: 0
2016-05-18 05:52:47,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 05:52:47,078 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C2A3F8E984214467BF842C4B96FAB623, mem on start (mb), free: 328, total: 370, max: 672
2016-05-18 05:52:47,082 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C2A3F8E984214467BF842C4B96FAB623, mem on close (mb), free: 328, total: 370, max: 672
2016-05-18 05:52:47,104 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-18 05:52:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.152
2016-05-18 05:52:47,152 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-18 05:52:47,164 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:47,164 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:47,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:52:47,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:47,184 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:47,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:47,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 05:52:47,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:47,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:47,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:47,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-18 05:52:47,255 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1599658029/.staging/job_local1599658029_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,256 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1599658029/.staging/job_local1599658029_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,286 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1599658029_0027/job_local1599658029_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,287 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1599658029_0027/job_local1599658029_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1599658029_0027
2016-05-18 05:52:47,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:47,292 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:47,297 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:47,298 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:47,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DCE20F48975A426AABFC983AEC0B4A79, ordinal: 0
2016-05-18 05:52:47,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 05:52:47,304 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCE20F48975A426AABFC983AEC0B4A79, mem on start (mb), free: 271, total: 370, max: 672
2016-05-18 05:52:47,306 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCE20F48975A426AABFC983AEC0B4A79, mem on close (mb), free: 271, total: 370, max: 672
2016-05-18 05:52:47,323 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-18 05:52:47,324 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.131
2016-05-18 05:52:47,365 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-18 05:52:47,377 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:47,377 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:47,393 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:52:47,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:47,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:47,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:47,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 05:52:47,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:47,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:47,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:47,403 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-18 05:52:47,453 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity184438042/.staging/job_local184438042_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,454 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity184438042/.staging/job_local184438042_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,484 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local184438042_0028/job_local184438042_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,485 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local184438042_0028/job_local184438042_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local184438042_0028
2016-05-18 05:52:47,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:47,490 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:47,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:47,495 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:47,501 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E94EDC18129C4AE18986F9DD878BB68E, ordinal: 0
2016-05-18 05:52:47,502 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,502 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 05:52:47,502 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E94EDC18129C4AE18986F9DD878BB68E, mem on start (mb), free: 215, total: 370, max: 672
2016-05-18 05:52:47,505 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E94EDC18129C4AE18986F9DD878BB68E, mem on close (mb), free: 215, total: 370, max: 672
2016-05-18 05:52:47,521 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-18 05:52:47,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.119
2016-05-18 05:52:47,561 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-18 05:52:47,572 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:47,573 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:47,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:52:47,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:47,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:47,597 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:47,597 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,597 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 05:52:47,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:47,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:47,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:47,599 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-18 05:52:47,649 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1295067485/.staging/job_local1295067485_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,650 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity1295067485/.staging/job_local1295067485_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,679 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1295067485_0029/job_local1295067485_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,681 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1295067485_0029/job_local1295067485_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1295067485_0029
2016-05-18 05:52:47,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:47,686 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:47,691 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:47,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:47,697 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0897867F9214BE198F53629DA2FF255, ordinal: 0
2016-05-18 05:52:47,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 05:52:47,699 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0897867F9214BE198F53629DA2FF255, mem on start (mb), free: 160, total: 370, max: 672
2016-05-18 05:52:47,701 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0897867F9214BE198F53629DA2FF255, mem on close (mb), free: 160, total: 370, max: 672
2016-05-18 05:52:47,715 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-18 05:52:47,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.118
2016-05-18 05:52:47,761 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-18 05:52:47,774 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:47,775 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:47,790 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-05-18 05:52:47,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:47,791 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:47,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:47,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 05:52:47,803 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:47,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:47,804 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:47,806 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-18 05:52:47,868 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2141779606/.staging/job_local2141779606_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,869 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2141779606/.staging/job_local2141779606_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,901 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2141779606_0030/job_local2141779606_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:47,902 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2141779606_0030/job_local2141779606_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:47,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2141779606_0030
2016-05-18 05:52:47,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:47,908 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:47,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:47,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:47,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E26A829D320E4D3C824D5D4809F93E33, ordinal: 0
2016-05-18 05:52:47,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:47,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 05:52:47,921 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E26A829D320E4D3C824D5D4809F93E33, mem on start (mb), free: 303, total: 362, max: 672
2016-05-18 05:52:47,923 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E26A829D320E4D3C824D5D4809F93E33, mem on close (mb), free: 303, total: 362, max: 672
2016-05-18 05:52:47,937 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-18 05:52:47,938 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.134
2016-05-18 05:52:47,980 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-18 05:52:47,992 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:47,992 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:48,008 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 05:52:48,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:52:48,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:52:48,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:52:48,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:48,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 05:52:48,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:52:48,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:52:48,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:52:48,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 05:52:48,067 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2061728084/.staging/job_local2061728084_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:48,068 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/tmp/cascading/staging/teamcity2061728084/.staging/job_local2061728084_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:48,099 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2061728084_0031/job_local2061728084_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 05:52:48,100 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2061728084_0031/job_local2061728084_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 05:52:48,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2061728084_0031
2016-05-18 05:52:48,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:52:48,107 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-05-18 05:52:48,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:52:48,113 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:52:48,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABFB0E7AC649411E8EBA0CE3C392853B, ordinal: 0
2016-05-18 05:52:48,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:52:48,118 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 05:52:48,118 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABFB0E7AC649411E8EBA0CE3C392853B, mem on start (mb), free: 244, total: 362, max: 672
2016-05-18 05:52:48,121 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABFB0E7AC649411E8EBA0CE3C392853B, mem on close (mb), free: 244, total: 362, max: 672
2016-05-18 05:52:48,136 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-18 05:52:48,136 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.120
2016-05-18 05:52:48,180 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 05:52:48,190 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:52:48,190 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 05:52:48,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 05:52:48,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:52:48,201 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'