2016-05-18 00:59:27,150 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 00:59:27,171 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-05-18 00:59:27,572 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-18 00:59:28,117 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 00:59:28,259 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 00:59:28,351 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:28,353 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 00:59:28,465 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 09D9596D4CD64F1BA492B05FE5A64900
2016-05-18 00:59:28,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.089
2016-05-18 00:59:28,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:28,619 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 00:59:28,768 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 00:59:28,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:28,770 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:28,771 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 00:59:28,771 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:28,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:28,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:28,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-18 00:59:29,256 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1696814602/.staging/job_local1696814602_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:29,257 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1696814602/.staging/job_local1696814602_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:29,419 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1696814602_0001/job_local1696814602_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:29,419 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1696814602_0001/job_local1696814602_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:29,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1696814602_0001
2016-05-18 00:59:29,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:29,525 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:29,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:29,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:29,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D1993A8633E545F3BF7E82D33112C634, ordinal: 0
2016-05-18 00:59:29,612 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:29,612 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 00:59:29,614 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D1993A8633E545F3BF7E82D33112C634, mem on start (mb), free: 182, total: 281, max: 672
2016-05-18 00:59:29,626 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D1993A8633E545F3BF7E82D33112C634, mem on close (mb), free: 181, total: 281, max: 672
2016-05-18 00:59:29,676 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-18 00:59:29,676 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.905
2016-05-18 00:59:29,763 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-18 00:59:29,787 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:29,788 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 00:59:29,878 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 00:59:29,880 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:29,880 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 00:59:29,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:29,898 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:29,899 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 00:59:29,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:29,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:29,900 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:29,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-18 00:59:29,980 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity365954387/.staging/job_local365954387_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:29,980 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity365954387/.staging/job_local365954387_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,051 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local365954387_0002/job_local365954387_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:30,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local365954387_0002/job_local365954387_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local365954387_0002
2016-05-18 00:59:30,055 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:30,063 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:30,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:30,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:30,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D044F7358CAD40B88EDAB5D0A77D5A67, ordinal: 0
2016-05-18 00:59:30,086 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:30,086 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 00:59:30,086 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D044F7358CAD40B88EDAB5D0A77D5A67, mem on start (mb), free: 234, total: 281, max: 672
2016-05-18 00:59:30,089 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D044F7358CAD40B88EDAB5D0A77D5A67, mem on close (mb), free: 234, total: 281, max: 672
2016-05-18 00:59:30,110 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-18 00:59:30,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.212
2016-05-18 00:59:30,191 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-18 00:59:30,213 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:30,214 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 00:59:30,278 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 00:59:30,280 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:30,280 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 00:59:30,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:30,301 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:30,301 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 00:59:30,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:30,302 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:30,304 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:30,304 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-18 00:59:30,407 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1709181562/.staging/job_local1709181562_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:30,408 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1709181562/.staging/job_local1709181562_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,470 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1709181562_0003/job_local1709181562_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:30,471 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1709181562_0003/job_local1709181562_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1709181562_0003
2016-05-18 00:59:30,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:30,481 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:30,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:30,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:30,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA856F7816B34EA0B3C470615BC3D30B, ordinal: 0
2016-05-18 00:59:30,508 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:30,509 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 00:59:30,509 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA856F7816B34EA0B3C470615BC3D30B, mem on start (mb), free: 184, total: 281, max: 672
2016-05-18 00:59:30,513 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA856F7816B34EA0B3C470615BC3D30B, mem on close (mb), free: 184, total: 281, max: 672
2016-05-18 00:59:30,542 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-18 00:59:30,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.241
2016-05-18 00:59:30,624 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-18 00:59:30,642 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:30,643 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 00:59:30,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 00:59:30,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:30,686 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 00:59:30,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:30,700 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:30,700 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 00:59:30,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:30,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:30,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:30,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-18 00:59:30,780 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity92632349/.staging/job_local92632349_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:30,780 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity92632349/.staging/job_local92632349_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,851 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local92632349_0004/job_local92632349_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:30,852 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local92632349_0004/job_local92632349_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:30,853 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local92632349_0004
2016-05-18 00:59:30,853 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:30,859 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:30,867 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:30,867 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:30,879 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DF097318F4304E6294309C94129F1B22, ordinal: 0
2016-05-18 00:59:30,880 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:30,880 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 00:59:30,880 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF097318F4304E6294309C94129F1B22, mem on start (mb), free: 368, total: 397, max: 672
2016-05-18 00:59:30,883 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF097318F4304E6294309C94129F1B22, mem on close (mb), free: 368, total: 397, max: 672
2016-05-18 00:59:30,911 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-18 00:59:30,911 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.210
2016-05-18 00:59:30,957 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-18 00:59:30,969 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:30,970 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 00:59:31,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-18 00:59:31,018 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:31,018 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 00:59:31,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:31,029 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,030 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 00:59:31,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:31,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:31,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:31,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-18 00:59:31,097 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity890564370/.staging/job_local890564370_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,097 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity890564370/.staging/job_local890564370_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,139 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local890564370_0005/job_local890564370_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,139 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local890564370_0005/job_local890564370_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local890564370_0005
2016-05-18 00:59:31,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:31,149 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:31,157 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:31,157 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:31,168 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F568044FC1A848EBB07D587DE24D73A8, ordinal: 0
2016-05-18 00:59:31,169 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,169 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 00:59:31,169 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F568044FC1A848EBB07D587DE24D73A8, mem on start (mb), free: 308, total: 397, max: 672
2016-05-18 00:59:31,173 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F568044FC1A848EBB07D587DE24D73A8, mem on close (mb), free: 308, total: 397, max: 672
2016-05-18 00:59:31,198 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-18 00:59:31,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.168
2016-05-18 00:59:31,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-18 00:59:31,263 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:31,264 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 00:59:31,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 00:59:31,296 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:31,297 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 00:59:31,310 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:31,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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 00:59:31,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:31,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:31,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:31,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-18 00:59:31,378 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity399199975/.staging/job_local399199975_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,378 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity399199975/.staging/job_local399199975_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,422 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local399199975_0006/job_local399199975_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,422 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local399199975_0006/job_local399199975_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local399199975_0006
2016-05-18 00:59:31,425 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:31,432 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:31,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:31,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:31,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A02414082DF843708CFC7C5F8CDBB97A, ordinal: 0
2016-05-18 00:59:31,450 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,451 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 00:59:31,451 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A02414082DF843708CFC7C5F8CDBB97A, mem on start (mb), free: 249, total: 397, max: 672
2016-05-18 00:59:31,454 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A02414082DF843708CFC7C5F8CDBB97A, mem on close (mb), free: 249, total: 397, max: 672
2016-05-18 00:59:31,474 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-18 00:59:31,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.164
2016-05-18 00:59:31,524 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-18 00:59:31,542 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:31,543 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 00:59:31,562 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 00:59:31,563 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:31,563 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-18 00:59:31,580 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:31,581 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 00:59:31,618 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 00:59:31,619 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:31,620 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 00:59:31,635 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:31,636 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,636 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 00:59:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:31,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-18 00:59:31,705 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity768165898/.staging/job_local768165898_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,706 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity768165898/.staging/job_local768165898_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,757 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local768165898_0007/job_local768165898_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:31,757 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local768165898_0007/job_local768165898_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:31,759 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local768165898_0007
2016-05-18 00:59:31,760 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:31,765 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:31,772 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:31,772 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:31,781 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D2E93EDE960E4B12A6AF6DBD5E612BAB, ordinal: 0
2016-05-18 00:59:31,782 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,782 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 00:59:31,782 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E93EDE960E4B12A6AF6DBD5E612BAB, mem on start (mb), free: 186, total: 397, max: 672
2016-05-18 00:59:31,786 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E93EDE960E4B12A6AF6DBD5E612BAB, mem on close (mb), free: 186, total: 397, max: 672
2016-05-18 00:59:31,804 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-18 00:59:31,805 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.169
2016-05-18 00:59:31,859 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-18 00:59:31,878 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:31,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 00:59:31,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 00:59:31,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:31,918 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 00:59:31,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:31,933 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:31,933 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 00:59:31,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:31,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:31,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:31,934 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-18 00:59:32,017 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1507550882/.staging/job_local1507550882_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,017 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1507550882/.staging/job_local1507550882_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1507550882_0008/job_local1507550882_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1507550882_0008/job_local1507550882_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1507550882_0008
2016-05-18 00:59:32,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:32,059 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:32,066 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:32,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:32,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C8C099CBF5FE4EA2B807B73E6C64D3AF, ordinal: 0
2016-05-18 00:59:32,076 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,076 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 00:59:32,076 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8C099CBF5FE4EA2B807B73E6C64D3AF, mem on start (mb), free: 359, total: 397, max: 672
2016-05-18 00:59:32,080 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8C099CBF5FE4EA2B807B73E6C64D3AF, mem on close (mb), free: 359, total: 397, max: 672
2016-05-18 00:59:32,099 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-18 00:59:32,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.166
2016-05-18 00:59:32,144 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-18 00:59:32,156 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:32,157 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 00:59:32,187 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 00:59:32,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:32,188 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 00:59:32,198 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:32,199 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,199 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 00:59:32,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:32,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:32,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:32,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 00:59:32,260 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1110984360/.staging/job_local1110984360_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,260 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1110984360/.staging/job_local1110984360_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,297 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1110984360_0009/job_local1110984360_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,297 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1110984360_0009/job_local1110984360_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1110984360_0009
2016-05-18 00:59:32,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:32,304 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:32,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:32,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:32,320 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC2608A97EFF4BE6BF86968412412FBE, ordinal: 0
2016-05-18 00:59:32,320 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,321 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 00:59:32,321 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC2608A97EFF4BE6BF86968412412FBE, mem on start (mb), free: 300, total: 397, max: 672
2016-05-18 00:59:32,325 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC2608A97EFF4BE6BF86968412412FBE, mem on close (mb), free: 300, total: 397, max: 672
2016-05-18 00:59:32,344 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-18 00:59:32,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.145
2016-05-18 00:59:32,389 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 00:59:32,402 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:32,403 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 00:59:32,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 00:59:32,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:32,434 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 00:59:32,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:32,448 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,448 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 00:59:32,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:32,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:32,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:32,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 00:59:32,515 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity2138316225/.staging/job_local2138316225_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,515 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity2138316225/.staging/job_local2138316225_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,557 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2138316225_0010/job_local2138316225_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,558 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2138316225_0010/job_local2138316225_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2138316225_0010
2016-05-18 00:59:32,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:32,564 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:32,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:32,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:32,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C13266C1B49A417A8B364D3CADA4265B, ordinal: 0
2016-05-18 00:59:32,583 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,583 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 00:59:32,583 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C13266C1B49A417A8B364D3CADA4265B, mem on start (mb), free: 242, total: 397, max: 672
2016-05-18 00:59:32,585 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 00:59:32,588 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 00:59:32,594 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 00:59:32,598 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C13266C1B49A417A8B364D3CADA4265B, mem on close (mb), free: 240, total: 397, max: 672
2016-05-18 00:59:32,599 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2138316225_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 00:59:32,601 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local2138316225_0010 state at FAILED
2016-05-18 00:59:32,602 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:32,603 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:32,603 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:32,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:32,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 00:59:32,605 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:32,605 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-18 00:59:32,606 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.157
2016-05-18 00:59:32,606 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-18 00:59:32,625 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:32,626 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 00:59:32,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2016-05-18 00:59:32,657 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:32,658 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-18 00:59:32,676 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:32,676 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 00:59:32,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 00:59:32,703 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:32,703 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 00:59:32,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:32,716 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,719 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 00:59:32,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:32,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:32,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:32,721 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 00:59:32,784 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1100143796/.staging/job_local1100143796_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,785 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1100143796/.staging/job_local1100143796_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,821 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1100143796_0011/job_local1100143796_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:32,821 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1100143796_0011/job_local1100143796_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:32,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1100143796_0011
2016-05-18 00:59:32,824 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:32,828 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:32,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:32,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:32,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C4A1FA8F68624EF980FA26242A85056F, ordinal: 0
2016-05-18 00:59:32,850 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,850 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 00:59:32,850 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4A1FA8F68624EF980FA26242A85056F, mem on start (mb), free: 191, total: 397, max: 672
2016-05-18 00:59:32,851 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 00:59:32,855 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 00:59:32,859 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 00:59:32,863 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4A1FA8F68624EF980FA26242A85056F, mem on close (mb), free: 191, total: 397, max: 672
2016-05-18 00:59:32,864 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1100143796_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 00:59:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1100143796_0011 state at FAILED
2016-05-18 00:59:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:32,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:32,866 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 00:59:32,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:32,867 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-18 00:59:32,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.151
2016-05-18 00:59:32,869 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-18 00:59:32,885 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:32,885 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 00:59:32,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 00:59:32,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:32,926 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 00:59:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:32,940 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:32,941 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 00:59:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:32,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:32,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 00:59:33,005 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity342280110/.staging/job_local342280110_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,005 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity342280110/.staging/job_local342280110_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local342280110_0012/job_local342280110_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local342280110_0012/job_local342280110_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local342280110_0012
2016-05-18 00:59:33,054 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:33,078 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:33,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:33,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:33,094 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E75DD7C080584291B8EE83207C26221A, ordinal: 0
2016-05-18 00:59:33,094 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,095 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 00:59:33,096 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E75DD7C080584291B8EE83207C26221A, mem on start (mb), free: 363, total: 384, max: 672
2016-05-18 00:59:33,097 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 00:59:33,098 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 00:59:33,098 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 00:59:33,106 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E75DD7C080584291B8EE83207C26221A, mem on close (mb), free: 363, total: 384, max: 672
2016-05-18 00:59:33,108 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local342280110_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 00:59:33,114 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local342280110_0012 state at FAILED
2016-05-18 00:59:33,114 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:33,114 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:33,114 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:33,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:33,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 00:59:33,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:33,115 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-18 00:59:33,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.175
2016-05-18 00:59:33,116 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-18 00:59:33,131 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,131 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 00:59:33,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 00:59:33,146 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:33,146 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-18 00:59:33,157 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,158 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 00:59:33,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 00:59:33,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:33,182 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 00:59:33,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:33,190 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,191 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 00:59:33,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:33,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:33,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:33,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-18 00:59:33,246 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1459002422/.staging/job_local1459002422_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,247 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1459002422/.staging/job_local1459002422_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,279 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1459002422_0013/job_local1459002422_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,280 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1459002422_0013/job_local1459002422_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,280 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1459002422_0013
2016-05-18 00:59:33,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:33,286 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:33,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:33,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:33,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F917101E58F84288ADC0A70AA7AB2D5C, ordinal: 0
2016-05-18 00:59:33,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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,303 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 00:59:33,303 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F917101E58F84288ADC0A70AA7AB2D5C, mem on start (mb), free: 315, total: 384, max: 672
2016-05-18 00:59:33,306 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F917101E58F84288ADC0A70AA7AB2D5C, mem on close (mb), free: 315, total: 384, max: 672
2016-05-18 00:59:33,325 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-18 00:59:33,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.135
2016-05-18 00:59:33,369 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-18 00:59:33,383 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,384 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 00:59:33,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 00:59:33,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:33,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-18 00:59:33,409 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,410 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 00:59:33,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 00:59:33,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:33,446 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 00:59:33,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:33,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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 00:59:33,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:33,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:33,459 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:33,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-18 00:59:33,512 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1868977625/.staging/job_local1868977625_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,513 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1868977625/.staging/job_local1868977625_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,549 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1868977625_0014/job_local1868977625_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,549 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1868977625_0014/job_local1868977625_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1868977625_0014
2016-05-18 00:59:33,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:33,557 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:33,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:33,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:33,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE692FF85A484532A48514951D4675EE, ordinal: 0
2016-05-18 00:59:33,571 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,571 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 00:59:33,571 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE692FF85A484532A48514951D4675EE, mem on start (mb), free: 256, total: 384, max: 672
2016-05-18 00:59:33,575 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE692FF85A484532A48514951D4675EE, mem on close (mb), free: 256, total: 384, max: 672
2016-05-18 00:59:33,597 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-18 00:59:33,598 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.140
2016-05-18 00:59:33,639 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-18 00:59:33,651 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,651 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 00:59:33,675 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 00:59:33,675 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:33,675 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 00:59:33,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:33,684 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,685 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 00:59:33,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:33,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:33,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:33,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-18 00:59:33,736 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1818096066/.staging/job_local1818096066_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,736 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1818096066/.staging/job_local1818096066_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,770 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1818096066_0015/job_local1818096066_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:33,771 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1818096066_0015/job_local1818096066_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:33,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1818096066_0015
2016-05-18 00:59:33,773 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:33,778 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:33,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:33,785 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:33,793 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF9278F378EB424791E647E95EE041D3, ordinal: 0
2016-05-18 00:59:33,794 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,795 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 00:59:33,795 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF9278F378EB424791E647E95EE041D3, mem on start (mb), free: 204, total: 384, max: 672
2016-05-18 00:59:33,800 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF9278F378EB424791E647E95EE041D3, mem on close (mb), free: 204, total: 384, max: 672
2016-05-18 00:59:33,819 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-18 00:59:33,819 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.134
2016-05-18 00:59:33,864 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-18 00:59:33,876 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:33,876 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 00:59:33,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 00:59:33,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:33,910 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 00:59:33,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:33,925 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:33,926 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 00:59:33,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:33,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:33,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:33,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-18 00:59:34,005 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity573611808/.staging/job_local573611808_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,006 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity573611808/.staging/job_local573611808_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,059 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local573611808_0016/job_local573611808_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,060 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local573611808_0016/job_local573611808_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local573611808_0016
2016-05-18 00:59:34,061 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:34,069 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:34,078 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:34,079 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:34,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EBE36ECDCF274D51A64B4297B9F3349C, ordinal: 0
2016-05-18 00:59:34,089 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,089 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 00:59:34,089 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBE36ECDCF274D51A64B4297B9F3349C, mem on start (mb), free: 150, total: 384, max: 672
2016-05-18 00:59:34,093 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EBE36ECDCF274D51A64B4297B9F3349C, mem on close (mb), free: 150, total: 384, max: 672
2016-05-18 00:59:34,115 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-18 00:59:34,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.190
2016-05-18 00:59:34,181 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-18 00:59:34,193 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:34,194 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 00:59:34,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 00:59:34,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:34,218 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 00:59:34,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:34,229 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,230 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 00:59:34,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:34,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:34,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:34,232 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-18 00:59:34,287 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1875863416/.staging/job_local1875863416_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,288 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1875863416/.staging/job_local1875863416_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,320 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1875863416_0017/job_local1875863416_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,320 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1875863416_0017/job_local1875863416_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1875863416_0017
2016-05-18 00:59:34,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:34,326 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:34,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:34,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:34,339 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E7A0BF2ED0E940EDB8BC3EE3AFF4F2F1, ordinal: 0
2016-05-18 00:59:34,341 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,342 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 00:59:34,342 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7A0BF2ED0E940EDB8BC3EE3AFF4F2F1, mem on start (mb), free: 313, total: 391, max: 672
2016-05-18 00:59:34,345 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7A0BF2ED0E940EDB8BC3EE3AFF4F2F1, mem on close (mb), free: 313, total: 391, max: 672
2016-05-18 00:59:34,366 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-18 00:59:34,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.137
2016-05-18 00:59:34,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-18 00:59:34,419 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:34,419 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 00:59:34,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 00:59:34,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:34,442 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 00:59:34,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:34,451 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,451 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 00:59:34,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:34,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:34,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:34,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-18 00:59:34,506 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity816944328/.staging/job_local816944328_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,506 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity816944328/.staging/job_local816944328_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,536 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local816944328_0018/job_local816944328_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,536 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local816944328_0018/job_local816944328_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local816944328_0018
2016-05-18 00:59:34,537 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:34,541 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:34,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:34,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:34,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E618039596AD41B2AC383259AD24C17A, ordinal: 0
2016-05-18 00:59:34,554 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,554 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 00:59:34,555 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E618039596AD41B2AC383259AD24C17A, mem on start (mb), free: 256, total: 391, max: 672
2016-05-18 00:59:34,557 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E618039596AD41B2AC383259AD24C17A, mem on close (mb), free: 256, total: 391, max: 672
2016-05-18 00:59:34,570 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-18 00:59:34,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.120
2016-05-18 00:59:34,612 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-18 00:59:34,622 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:34,622 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 00:59:34,632 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 00:59:34,632 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:34,632 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-18 00:59:34,642 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:34,642 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 00:59:34,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 00:59:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:34,661 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 00:59:34,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:34,669 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,669 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 00:59:34,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:34,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:34,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:34,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-18 00:59:34,720 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity417703549/.staging/job_local417703549_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,720 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity417703549/.staging/job_local417703549_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,751 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local417703549_0019/job_local417703549_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,752 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local417703549_0019/job_local417703549_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,752 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local417703549_0019
2016-05-18 00:59:34,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:34,757 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:34,763 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:34,763 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:34,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EC3959E9E14847128F448325FFD034C9, ordinal: 0
2016-05-18 00:59:34,770 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,770 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 00:59:34,770 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC3959E9E14847128F448325FFD034C9, mem on start (mb), free: 194, total: 391, max: 672
2016-05-18 00:59:34,773 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC3959E9E14847128F448325FFD034C9, mem on close (mb), free: 194, total: 391, max: 672
2016-05-18 00:59:34,787 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-18 00:59:34,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.118
2016-05-18 00:59:34,827 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-18 00:59:34,837 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:34,837 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 00:59:34,864 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 00:59:34,865 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:34,865 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 00:59:34,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:34,872 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,873 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 00:59:34,873 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:34,873 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:34,873 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:34,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-18 00:59:34,924 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1825503644/.staging/job_local1825503644_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,924 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1825503644/.staging/job_local1825503644_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,972 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1825503644_0020/job_local1825503644_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:34,972 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1825503644_0020/job_local1825503644_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:34,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1825503644_0020
2016-05-18 00:59:34,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:34,977 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:34,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:34,983 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:34,990 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C77DE354DB9447858F0629BB481CB610, ordinal: 0
2016-05-18 00:59:34,991 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:34,992 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 00:59:34,992 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C77DE354DB9447858F0629BB481CB610, mem on start (mb), free: 357, total: 390, max: 672
2016-05-18 00:59:34,995 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C77DE354DB9447858F0629BB481CB610, mem on close (mb), free: 357, total: 390, max: 672
2016-05-18 00:59:35,016 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-18 00:59:35,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.144
2016-05-18 00:59:35,054 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-18 00:59:35,067 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,067 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 00:59:35,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 00:59:35,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:35,086 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 00:59:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:35,099 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,099 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 00:59:35,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:35,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:35,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:35,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 00:59:35,152 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1491496801/.staging/job_local1491496801_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,152 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1491496801/.staging/job_local1491496801_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,184 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1491496801_0021/job_local1491496801_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,184 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1491496801_0021/job_local1491496801_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1491496801_0021
2016-05-18 00:59:35,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:35,189 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:35,194 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:35,194 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:35,203 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A2B72D2D022C4BBD8E1036DFFF805A4E, ordinal: 0
2016-05-18 00:59:35,204 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,204 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 00:59:35,204 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2B72D2D022C4BBD8E1036DFFF805A4E, mem on start (mb), free: 302, total: 390, max: 672
2016-05-18 00:59:35,205 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 00:59:35,206 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 00:59:35,207 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 00:59:35,209 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A2B72D2D022C4BBD8E1036DFFF805A4E, mem on close (mb), free: 301, total: 390, max: 672
2016-05-18 00:59:35,210 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1491496801_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 00:59:35,217 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1491496801_0021 state at FAILED
2016-05-18 00:59:35,217 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:35,217 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:35,218 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:35,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:35,218 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 00:59:35,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:35,219 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-18 00:59:35,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.120
2016-05-18 00:59:35,220 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-18 00:59:35,235 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,236 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 00:59:35,247 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 00:59:35,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:35,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-18 00:59:35,258 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,258 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 00:59:35,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 00:59:35,276 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:35,276 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 00:59:35,284 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:35,284 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,285 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 00:59:35,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:35,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:35,285 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:35,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 00:59:35,336 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity448302984/.staging/job_local448302984_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,336 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity448302984/.staging/job_local448302984_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,366 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local448302984_0022/job_local448302984_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,367 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local448302984_0022/job_local448302984_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local448302984_0022
2016-05-18 00:59:35,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:35,372 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:35,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:35,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:35,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCEB4060B326435DBC1C11FEB65320AE, ordinal: 0
2016-05-18 00:59:35,385 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,385 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 00:59:35,385 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCEB4060B326435DBC1C11FEB65320AE, mem on start (mb), free: 255, total: 390, max: 672
2016-05-18 00:59:35,386 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 00:59:35,388 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 00:59:35,390 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 00:59:35,393 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCEB4060B326435DBC1C11FEB65320AE, mem on close (mb), free: 254, total: 390, max: 672
2016-05-18 00:59:35,397 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local448302984_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 00:59:35,404 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local448302984_0022 state at FAILED
2016-05-18 00:59:35,404 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:35,404 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:35,404 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:35,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:35,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 00:59:35,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:35,413 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-18 00:59:35,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.128
2016-05-18 00:59:35,413 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-18 00:59:35,424 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,425 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 00:59:35,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 00:59:35,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:35,453 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 00:59:35,460 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:35,460 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,461 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 00:59:35,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:35,461 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:35,462 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:35,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 00:59:35,512 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity458063354/.staging/job_local458063354_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,512 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity458063354/.staging/job_local458063354_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,541 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local458063354_0023/job_local458063354_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,541 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local458063354_0023/job_local458063354_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local458063354_0023
2016-05-18 00:59:35,542 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:35,548 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:35,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:35,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:35,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BF19DAF6A83142988DEC915B873FD756, ordinal: 0
2016-05-18 00:59:35,561 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,561 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 00:59:35,561 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BF19DAF6A83142988DEC915B873FD756, mem on start (mb), free: 213, total: 390, max: 672
2016-05-18 00:59:35,562 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 00:59:35,564 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 00:59:35,565 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 00:59:35,565 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BF19DAF6A83142988DEC915B873FD756, mem on close (mb), free: 212, total: 390, max: 672
2016-05-18 00:59:35,566 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local458063354_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 00:59:35,575 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local458063354_0023 state at FAILED
2016-05-18 00:59:35,575 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 00:59:35,575 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 00:59:35,575 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 00:59:35,576 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 00:59:35,576 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 00:59:35,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 00:59:35,577 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-18 00:59:35,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.117
2016-05-18 00:59:35,579 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-18 00:59:35,591 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,591 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 00:59:35,608 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:59:35,608 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:35,609 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 00:59:35,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:35,616 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,616 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 00:59:35,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:35,616 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:35,617 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:35,617 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-18 00:59:35,666 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1228117790/.staging/job_local1228117790_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,667 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1228117790/.staging/job_local1228117790_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,698 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1228117790_0024/job_local1228117790_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,698 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1228117790_0024/job_local1228117790_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1228117790_0024
2016-05-18 00:59:35,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:35,704 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:35,710 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:35,710 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:35,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DDBF6D3924744234B9657EDEC07D48BB, ordinal: 0
2016-05-18 00:59:35,716 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,717 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 00:59:35,717 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDBF6D3924744234B9657EDEC07D48BB, mem on start (mb), free: 170, total: 390, max: 672
2016-05-18 00:59:35,722 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDBF6D3924744234B9657EDEC07D48BB, mem on close (mb), free: 170, total: 390, max: 672
2016-05-18 00:59:35,744 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-18 00:59:35,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.129
2016-05-18 00:59:35,789 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-18 00:59:35,799 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,799 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 00:59:35,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 00:59:35,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:35,809 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-18 00:59:35,830 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:35,831 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 00:59:35,848 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:59:35,849 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:35,849 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 00:59:35,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:35,856 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,856 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 00:59:35,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:35,856 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:35,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:35,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-18 00:59:35,906 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity103940734/.staging/job_local103940734_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,906 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity103940734/.staging/job_local103940734_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,935 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local103940734_0025/job_local103940734_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:35,935 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local103940734_0025/job_local103940734_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:35,936 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local103940734_0025
2016-05-18 00:59:35,937 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:35,941 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:35,946 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:35,946 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:35,951 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D70BE92CA42C40DBA04763D0F6147CB4, ordinal: 0
2016-05-18 00:59:35,952 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:35,952 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 00:59:35,952 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D70BE92CA42C40DBA04763D0F6147CB4, mem on start (mb), free: 328, total: 391, max: 672
2016-05-18 00:59:35,954 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D70BE92CA42C40DBA04763D0F6147CB4, mem on close (mb), free: 328, total: 391, max: 672
2016-05-18 00:59:35,971 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-18 00:59:35,971 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.115
2016-05-18 00:59:36,010 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-18 00:59:36,021 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,021 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 00:59:36,031 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 00:59:36,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:36,032 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-18 00:59:36,044 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,044 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 00:59:36,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 00:59:36,064 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:36,065 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 00:59:36,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:36,076 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,076 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 00:59:36,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:36,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:36,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:36,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-18 00:59:36,128 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1799286975/.staging/job_local1799286975_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,128 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1799286975/.staging/job_local1799286975_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,166 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1799286975_0026/job_local1799286975_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,167 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1799286975_0026/job_local1799286975_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,169 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1799286975_0026
2016-05-18 00:59:36,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:36,173 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:36,178 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:36,178 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:36,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA1FCFD584384801803CAC1061A5AF05, ordinal: 0
2016-05-18 00:59:36,184 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 00:59:36,184 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1FCFD584384801803CAC1061A5AF05, mem on start (mb), free: 266, total: 391, max: 672
2016-05-18 00:59:36,187 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1FCFD584384801803CAC1061A5AF05, mem on close (mb), free: 266, total: 391, max: 672
2016-05-18 00:59:36,204 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-18 00:59:36,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.127
2016-05-18 00:59:36,249 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-18 00:59:36,265 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,266 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 00:59:36,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 00:59:36,287 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:36,287 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 00:59:36,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:36,298 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,298 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 00:59:36,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:36,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:36,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:36,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-18 00:59:36,371 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1555845342/.staging/job_local1555845342_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,371 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1555845342/.staging/job_local1555845342_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,407 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1555845342_0027/job_local1555845342_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,407 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1555845342_0027/job_local1555845342_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1555845342_0027
2016-05-18 00:59:36,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:36,413 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:36,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:36,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:36,424 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E4EF887138CA4B61B9D2DF4278448194, ordinal: 0
2016-05-18 00:59:36,425 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,425 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 00:59:36,425 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4EF887138CA4B61B9D2DF4278448194, mem on start (mb), free: 208, total: 391, max: 672
2016-05-18 00:59:36,428 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4EF887138CA4B61B9D2DF4278448194, mem on close (mb), free: 208, total: 391, max: 672
2016-05-18 00:59:36,442 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-18 00:59:36,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.144
2016-05-18 00:59:36,482 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-18 00:59:36,492 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,492 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 00:59:36,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 00:59:36,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:36,509 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 00:59:36,517 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:36,518 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,518 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 00:59:36,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:36,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:36,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:36,519 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-18 00:59:36,571 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity319763810/.staging/job_local319763810_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,571 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity319763810/.staging/job_local319763810_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,601 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local319763810_0028/job_local319763810_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,601 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local319763810_0028/job_local319763810_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local319763810_0028
2016-05-18 00:59:36,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:36,606 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:36,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:36,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:36,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8833355655F4C00965278CCD8F57FDA, ordinal: 0
2016-05-18 00:59:36,617 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,617 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 00:59:36,617 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8833355655F4C00965278CCD8F57FDA, mem on start (mb), free: 151, total: 391, max: 672
2016-05-18 00:59:36,619 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8833355655F4C00965278CCD8F57FDA, mem on close (mb), free: 151, total: 391, max: 672
2016-05-18 00:59:36,635 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-18 00:59:36,636 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.118
2016-05-18 00:59:36,683 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-18 00:59:36,693 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,694 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 00:59:36,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:59:36,710 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:36,711 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 00:59:36,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:36,717 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,717 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 00:59:36,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:36,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:36,718 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:36,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-18 00:59:36,767 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1780875187/.staging/job_local1780875187_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,767 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1780875187/.staging/job_local1780875187_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,797 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1780875187_0029/job_local1780875187_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,797 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1780875187_0029/job_local1780875187_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1780875187_0029
2016-05-18 00:59:36,798 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:36,802 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:36,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:36,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:36,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC51E5481CE84F79B3EDDE5740B7B840, ordinal: 0
2016-05-18 00:59:36,814 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,814 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 00:59:36,814 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC51E5481CE84F79B3EDDE5740B7B840, mem on start (mb), free: 312, total: 390, max: 672
2016-05-18 00:59:36,817 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC51E5481CE84F79B3EDDE5740B7B840, mem on close (mb), free: 312, total: 390, max: 672
2016-05-18 00:59:36,831 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-18 00:59:36,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.114
2016-05-18 00:59:36,870 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-18 00:59:36,879 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:36,879 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 00:59:36,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 00:59:36,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:36,899 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 00:59:36,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:36,908 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:36,908 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 00:59:36,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:36,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:36,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:36,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-18 00:59:36,961 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1807355259/.staging/job_local1807355259_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,961 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity1807355259/.staging/job_local1807355259_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,991 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1807355259_0030/job_local1807355259_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:36,992 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1807355259_0030/job_local1807355259_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:36,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1807355259_0030
2016-05-18 00:59:36,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:36,998 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:37,005 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:37,005 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:37,011 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C745B8177F2C4C868EFDD03B3FBD035E, ordinal: 0
2016-05-18 00:59:37,011 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:37,012 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 00:59:37,012 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C745B8177F2C4C868EFDD03B3FBD035E, mem on start (mb), free: 254, total: 390, max: 672
2016-05-18 00:59:37,014 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C745B8177F2C4C868EFDD03B3FBD035E, mem on close (mb), free: 254, total: 390, max: 672
2016-05-18 00:59:37,027 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-18 00:59:37,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.119
2016-05-18 00:59:37,073 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-18 00:59:37,089 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:37,090 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 00:59:37,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 00:59:37,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:59:37,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 00:59:37,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 00:59:37,114 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:37,114 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 00:59:37,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 00:59:37,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 00:59:37,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 00:59:37,116 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 00:59:37,172 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity46563931/.staging/job_local46563931_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:37,172 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/tmp/cascading/staging/teamcity46563931/.staging/job_local46563931_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:37,203 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local46563931_0031/job_local46563931_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-05-18 00:59:37,203 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local46563931_0031/job_local46563931_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-05-18 00:59:37,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local46563931_0031
2016-05-18 00:59:37,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 00:59:37,210 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/classes/test/data/nums.20.txt
2016-05-18 00:59:37,216 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 00:59:37,217 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 00:59:37,222 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EEBE36EEBAB14435ADC6AE09A66DC4AB, ordinal: 0
2016-05-18 00:59:37,223 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.3.x/build/classes/test/data/nums.20.txt"]
2016-05-18 00:59:37,224 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.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 00:59:37,224 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEBE36EEBAB14435ADC6AE09A66DC4AB, mem on start (mb), free: 197, total: 390, max: 672
2016-05-18 00:59:37,227 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEBE36EEBAB14435ADC6AE09A66DC4AB, mem on close (mb), free: 197, total: 390, max: 672
2016-05-18 00:59:37,240 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-18 00:59:37,240 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.125
2016-05-18 00:59:37,277 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 00:59:37,286 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:59:37,287 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 00:59:37,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 00:59:37,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 00:59:37,296 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.3.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'