2016-01-15 02:25:58,299 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 02:25:58,330 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-01-15 02:25:58,865 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-15 02:25:59,558 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-15 02:25:59,718 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 02:25:59,842 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:25:59,844 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:25:59,950 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4705649D8D0543F48A831A29BFF3E0D5
2016-01-15 02:26:00,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.087
2016-01-15 02:26:00,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:00,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:00,258 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 02:26:00,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:00,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:00,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-15 02:26:00,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:00,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:00,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:00,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-15 02:26:00,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local576359677_0001
2016-01-15 02:26:00,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:01,041 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:01,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:01,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:01,082 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C4D82C884B504574A96A32E2A1844AA2, ordinal: 0
2016-01-15 02:26:01,141 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:01,141 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-15 02:26:01,143 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4D82C884B504574A96A32E2A1844AA2, mem on start (mb), free: 162, total: 223, max: 672
2016-01-15 02:26:01,160 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4D82C884B504574A96A32E2A1844AA2, mem on close (mb), free: 162, total: 223, max: 672
2016-01-15 02:26:01,210 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-15 02:26:01,210 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.949
2016-01-15 02:26:01,299 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-15 02:26:01,326 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:01,326 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:01,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-15 02:26:01,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:01,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:01,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:01,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:01,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-15 02:26:01,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:01,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:01,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:01,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-15 02:26:01,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1866143456_0002
2016-01-15 02:26:01,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:01,582 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:01,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:01,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:01,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3E9533052E24DA39489380C9389DBD2, ordinal: 0
2016-01-15 02:26:01,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:01,601 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-15 02:26:01,601 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E9533052E24DA39489380C9389DBD2, mem on start (mb), free: 215, total: 281, max: 672
2016-01-15 02:26:01,604 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E9533052E24DA39489380C9389DBD2, mem on close (mb), free: 215, total: 281, max: 672
2016-01-15 02:26:01,625 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-15 02:26:01,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.216
2016-01-15 02:26:01,712 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-15 02:26:01,743 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:01,744 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:01,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-01-15 02:26:01,819 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:01,820 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:01,841 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:01,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:01,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-15 02:26:01,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:01,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:01,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:01,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-15 02:26:02,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local223626176_0003
2016-01-15 02:26:02,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:02,086 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:02,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:02,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:02,103 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B51BDD6E44EB44639694302BCAB8EF4A, ordinal: 0
2016-01-15 02:26:02,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-15 02:26:02,105 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B51BDD6E44EB44639694302BCAB8EF4A, mem on start (mb), free: 154, total: 281, max: 672
2016-01-15 02:26:02,108 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B51BDD6E44EB44639694302BCAB8EF4A, mem on close (mb), free: 154, total: 281, max: 672
2016-01-15 02:26:02,157 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-15 02:26:02,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.315
2016-01-15 02:26:02,218 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-15 02:26:02,234 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:02,234 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:02,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-15 02:26:02,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:02,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:02,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:02,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-15 02:26:02,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:02,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:02,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:02,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-15 02:26:02,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local64575238_0004
2016-01-15 02:26:02,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:02,444 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:02,451 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:02,452 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:02,461 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DEB5DCB90293401FA01F3505116CD417, ordinal: 0
2016-01-15 02:26:02,462 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,462 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-15 02:26:02,463 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEB5DCB90293401FA01F3505116CD417, mem on start (mb), free: 217, total: 281, max: 672
2016-01-15 02:26:02,466 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEB5DCB90293401FA01F3505116CD417, mem on close (mb), free: 217, total: 281, max: 672
2016-01-15 02:26:02,483 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-15 02:26:02,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.191
2016-01-15 02:26:02,540 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-15 02:26:02,557 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:02,557 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:02,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-15 02:26:02,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:02,603 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:02,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:02,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-15 02:26:02,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:02,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:02,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:02,621 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-15 02:26:02,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local661154751_0005
2016-01-15 02:26:02,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:02,754 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:02,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:02,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:02,775 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF6173DEEA4F4D9982B4F15EE29D7F8B, ordinal: 0
2016-01-15 02:26:02,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-15 02:26:02,777 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6173DEEA4F4D9982B4F15EE29D7F8B, mem on start (mb), free: 161, total: 281, max: 672
2016-01-15 02:26:02,782 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6173DEEA4F4D9982B4F15EE29D7F8B, mem on close (mb), free: 161, total: 281, max: 672
2016-01-15 02:26:02,804 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-15 02:26:02,804 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.185
2016-01-15 02:26:02,880 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-15 02:26:02,896 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:02,896 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:02,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-15 02:26:02,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:02,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:02,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:02,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:02,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-15 02:26:02,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:02,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:02,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:02,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-15 02:26:03,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local912912508_0006
2016-01-15 02:26:03,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:03,058 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:03,064 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:03,064 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:03,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE518F43B61B4DC5B6689EA05DE986F9, ordinal: 0
2016-01-15 02:26:03,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-15 02:26:03,076 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE518F43B61B4DC5B6689EA05DE986F9, mem on start (mb), free: 318, total: 395, max: 672
2016-01-15 02:26:03,079 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE518F43B61B4DC5B6689EA05DE986F9, mem on close (mb), free: 318, total: 395, max: 672
2016-01-15 02:26:03,098 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-15 02:26:03,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.144
2016-01-15 02:26:03,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-15 02:26:03,167 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:03,167 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:03,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-15 02:26:03,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:03,185 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-15 02:26:03,198 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:03,198 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:03,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-15 02:26:03,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:03,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:03,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:03,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-15 02:26:03,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:03,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:03,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:03,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-15 02:26:03,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1397923266_0007
2016-01-15 02:26:03,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:03,375 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:03,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:03,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:03,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A947BA8B7C0A440CB87763F74FE128C2, ordinal: 0
2016-01-15 02:26:03,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-15 02:26:03,391 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A947BA8B7C0A440CB87763F74FE128C2, mem on start (mb), free: 238, total: 395, max: 672
2016-01-15 02:26:03,394 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A947BA8B7C0A440CB87763F74FE128C2, mem on close (mb), free: 238, total: 395, max: 672
2016-01-15 02:26:03,413 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-15 02:26:03,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.166
2016-01-15 02:26:03,475 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-15 02:26:03,494 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:03,494 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:03,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 02:26:03,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:03,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:03,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:03,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-15 02:26:03,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:03,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:03,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:03,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-15 02:26:03,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1272516579_0008
2016-01-15 02:26:03,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:03,677 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:03,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:03,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:03,691 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E3AB15F8D488456AB4F9C15DE311D838, ordinal: 0
2016-01-15 02:26:03,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,693 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-15 02:26:03,693 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3AB15F8D488456AB4F9C15DE311D838, mem on start (mb), free: 166, total: 395, max: 672
2016-01-15 02:26:03,696 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3AB15F8D488456AB4F9C15DE311D838, mem on close (mb), free: 166, total: 395, max: 672
2016-01-15 02:26:03,717 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-15 02:26:03,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.175
2016-01-15 02:26:03,792 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-15 02:26:03,805 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:03,806 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:03,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-15 02:26:03,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:03,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-15 02:26:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:03,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:03,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-15 02:26:03,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1099851861_0009
2016-01-15 02:26:03,949 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:03,955 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:03,961 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:03,961 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:03,968 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0620B6B701942BEADA4D92D79A98816, ordinal: 0
2016-01-15 02:26:03,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:03,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-15 02:26:03,969 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0620B6B701942BEADA4D92D79A98816, mem on start (mb), free: 314, total: 390, max: 672
2016-01-15 02:26:03,972 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0620B6B701942BEADA4D92D79A98816, mem on close (mb), free: 314, total: 390, max: 672
2016-01-15 02:26:03,995 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-15 02:26:03,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.143
2016-01-15 02:26:04,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-15 02:26:04,059 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,059 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-15 02:26:04,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:04,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:04,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:04,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-15 02:26:04,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:04,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:04,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:04,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-15 02:26:04,192 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1806906712_0010
2016-01-15 02:26:04,192 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:04,198 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:04,203 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:04,203 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:04,214 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E53668ADAA1648F09E24E3E3A0003A04, ordinal: 0
2016-01-15 02:26:04,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,215 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-15 02:26:04,215 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E53668ADAA1648F09E24E3E3A0003A04, mem on start (mb), free: 241, total: 390, max: 672
2016-01-15 02:26:04,218 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,220 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,221 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,223 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E53668ADAA1648F09E24E3E3A0003A04, mem on close (mb), free: 241, total: 390, max: 672
2016-01-15 02:26:04,224 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1806906712_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,227 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1806906712_0010 state at FAILED
2016-01-15 02:26:04,228 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:04,234 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:04,234 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:04,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:04,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-15 02:26:04,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:04,236 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-15 02:26:04,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.136
2016-01-15 02:26:04,237 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-15 02:26:04,251 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,252 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-15 02:26:04,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:04,269 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-15 02:26:04,284 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,284 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,312 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 02:26:04,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:04,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:04,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:04,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-15 02:26:04,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:04,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:04,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:04,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-15 02:26:04,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local345632581_0011
2016-01-15 02:26:04,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:04,441 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:04,446 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:04,446 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:04,453 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABA6F2FE101844F88625262D3648364F, ordinal: 0
2016-01-15 02:26:04,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-15 02:26:04,454 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABA6F2FE101844F88625262D3648364F, mem on start (mb), free: 178, total: 390, max: 672
2016-01-15 02:26:04,455 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,456 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,457 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,460 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABA6F2FE101844F88625262D3648364F, mem on close (mb), free: 178, total: 390, max: 672
2016-01-15 02:26:04,465 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local345632581_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local345632581_0011 state at FAILED
2016-01-15 02:26:04,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:04,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:04,468 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:04,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:04,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-15 02:26:04,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:04,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] shutting down job executor
2016-01-15 02:26:04,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] shutdown complete
2016-01-15 02:26:04,470 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-15 02:26:04,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.146
2016-01-15 02:26:04,471 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-15 02:26:04,486 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,487 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-15 02:26:04,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:04,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:04,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:04,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-15 02:26:04,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local259819965_0012
2016-01-15 02:26:04,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:04,638 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:04,643 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:04,643 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:04,649 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E4906641775D4F108026B8F176F4B6D3, ordinal: 0
2016-01-15 02:26:04,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-15 02:26:04,650 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4906641775D4F108026B8F176F4B6D3, mem on start (mb), free: 355, total: 394, max: 672
2016-01-15 02:26:04,651 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,652 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,654 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,655 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4906641775D4F108026B8F176F4B6D3, mem on close (mb), free: 355, total: 394, max: 672
2016-01-15 02:26:04,657 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local259819965_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:04,664 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local259819965_0012 state at FAILED
2016-01-15 02:26:04,664 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:04,665 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:04,665 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:04,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:04,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-15 02:26:04,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:04,675 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-15 02:26:04,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.149
2016-01-15 02:26:04,680 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-15 02:26:04,694 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,694 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-15 02:26:04,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:04,708 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-15 02:26:04,721 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,721 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-15 02:26:04,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:04,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:04,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:04,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-15 02:26:04,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local453598060_0013
2016-01-15 02:26:04,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:04,850 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:04,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:04,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:04,863 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8EFDF7E2032434C8277B7B084A52369, ordinal: 0
2016-01-15 02:26:04,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:04,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-15 02:26:04,864 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8EFDF7E2032434C8277B7B084A52369, mem on start (mb), free: 290, total: 394, max: 672
2016-01-15 02:26:04,868 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8EFDF7E2032434C8277B7B084A52369, mem on close (mb), free: 290, total: 394, max: 672
2016-01-15 02:26:04,891 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-15 02:26:04,892 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.135
2016-01-15 02:26:04,936 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-15 02:26:04,952 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,952 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:04,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-01-15 02:26:04,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:04,971 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-15 02:26:04,984 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:04,985 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:05,009 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-15 02:26:05,009 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:05,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:05,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:05,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-15 02:26:05,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:05,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:05,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:05,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-15 02:26:05,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local360166198_0014
2016-01-15 02:26:05,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:05,123 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:05,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:05,129 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:05,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CBF8EBBB8E0A4D7E9732FEB0A623A8B2, ordinal: 0
2016-01-15 02:26:05,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-15 02:26:05,136 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBF8EBBB8E0A4D7E9732FEB0A623A8B2, mem on start (mb), free: 211, total: 394, max: 672
2016-01-15 02:26:05,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBF8EBBB8E0A4D7E9732FEB0A623A8B2, mem on close (mb), free: 211, total: 394, max: 672
2016-01-15 02:26:05,156 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-15 02:26:05,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.138
2016-01-15 02:26:05,205 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-15 02:26:05,218 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:05,219 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:05,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 02:26:05,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:05,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:05,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:05,256 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-15 02:26:05,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:05,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:05,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:05,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-15 02:26:05,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local11872289_0015
2016-01-15 02:26:05,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:05,361 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:05,367 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:05,367 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:05,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B115FAA554774FCA8D599B2A53D58754, ordinal: 0
2016-01-15 02:26:05,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-15 02:26:05,374 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B115FAA554774FCA8D599B2A53D58754, mem on start (mb), free: 366, total: 394, max: 672
2016-01-15 02:26:05,376 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B115FAA554774FCA8D599B2A53D58754, mem on close (mb), free: 366, total: 394, max: 672
2016-01-15 02:26:05,390 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-15 02:26:05,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.134
2016-01-15 02:26:05,441 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-15 02:26:05,453 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:05,454 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:05,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-15 02:26:05,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:05,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:05,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-15 02:26:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:05,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-15 02:26:05,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local537559288_0016
2016-01-15 02:26:05,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:05,634 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:05,641 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:05,641 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:05,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8F3105A62654E9FBA610C996B513D53, ordinal: 0
2016-01-15 02:26:05,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-15 02:26:05,652 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8F3105A62654E9FBA610C996B513D53, mem on start (mb), free: 299, total: 394, max: 672
2016-01-15 02:26:05,655 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8F3105A62654E9FBA610C996B513D53, mem on close (mb), free: 299, total: 394, max: 672
2016-01-15 02:26:05,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-15 02:26:05,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.175
2016-01-15 02:26:05,726 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-15 02:26:05,738 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:05,739 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:05,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-15 02:26:05,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:05,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:05,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:05,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-15 02:26:05,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:05,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:05,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:05,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-15 02:26:05,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local569284832_0017
2016-01-15 02:26:05,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:05,873 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:05,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:05,878 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:05,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDCB37DB3A3043E9B7493B270CBBBAB5, ordinal: 0
2016-01-15 02:26:05,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-15 02:26:05,886 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDCB37DB3A3043E9B7493B270CBBBAB5, mem on start (mb), free: 234, total: 394, max: 672
2016-01-15 02:26:05,889 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDCB37DB3A3043E9B7493B270CBBBAB5, mem on close (mb), free: 234, total: 394, max: 672
2016-01-15 02:26:05,902 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-15 02:26:05,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.131
2016-01-15 02:26:05,946 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-15 02:26:05,958 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:05,959 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:05,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-15 02:26:05,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:05,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:05,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:05,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-15 02:26:06,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1645639076_0018
2016-01-15 02:26:06,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:06,087 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:06,094 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:06,094 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:06,103 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9650F0FE556482DBF2E5BB676FCD961, ordinal: 0
2016-01-15 02:26:06,103 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-15 02:26:06,104 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9650F0FE556482DBF2E5BB676FCD961, mem on start (mb), free: 169, total: 394, max: 672
2016-01-15 02:26:06,106 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9650F0FE556482DBF2E5BB676FCD961, mem on close (mb), free: 169, total: 394, max: 672
2016-01-15 02:26:06,127 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-15 02:26:06,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.135
2016-01-15 02:26:06,185 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-15 02:26:06,197 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,198 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-01-15 02:26:06,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:06,209 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-15 02:26:06,221 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,221 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-15 02:26:06,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:06,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:06,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:06,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-15 02:26:06,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:06,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:06,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:06,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-15 02:26:06,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1505874888_0019
2016-01-15 02:26:06,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:06,343 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:06,348 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:06,348 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:06,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E3FDBA3C090747D6A9996851697B5FE7, ordinal: 0
2016-01-15 02:26:06,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-15 02:26:06,355 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3FDBA3C090747D6A9996851697B5FE7, mem on start (mb), free: 318, total: 395, max: 672
2016-01-15 02:26:06,357 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E3FDBA3C090747D6A9996851697B5FE7, mem on close (mb), free: 318, total: 395, max: 672
2016-01-15 02:26:06,373 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-15 02:26:06,374 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.124
2016-01-15 02:26:06,418 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-15 02:26:06,429 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,430 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 02:26:06,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:06,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:06,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:06,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-15 02:26:06,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:06,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:06,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:06,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-15 02:26:06,555 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1476777885_0020
2016-01-15 02:26:06,555 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:06,559 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:06,564 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:06,564 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:06,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA7F5F8BB9DF4ADF83A07C0F24611653, ordinal: 0
2016-01-15 02:26:06,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-15 02:26:06,571 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA7F5F8BB9DF4ADF83A07C0F24611653, mem on start (mb), free: 244, total: 395, max: 672
2016-01-15 02:26:06,577 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA7F5F8BB9DF4ADF83A07C0F24611653, mem on close (mb), free: 244, total: 395, max: 672
2016-01-15 02:26:06,589 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-15 02:26:06,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.127
2016-01-15 02:26:06,631 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-15 02:26:06,644 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,645 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 02:26:06,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:06,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:06,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:06,676 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-15 02:26:06,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local525687918_0021
2016-01-15 02:26:06,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:06,782 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:06,788 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:06,788 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:06,796 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDE8AD44236444B39F6E4E591009806D, ordinal: 0
2016-01-15 02:26:06,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-15 02:26:06,797 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDE8AD44236444B39F6E4E591009806D, mem on start (mb), free: 170, total: 395, max: 672
2016-01-15 02:26:06,798 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:06,799 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:06,799 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:06,800 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDE8AD44236444B39F6E4E591009806D, mem on close (mb), free: 170, total: 395, max: 672
2016-01-15 02:26:06,801 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local525687918_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:06,810 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local525687918_0021 state at FAILED
2016-01-15 02:26:06,810 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:06,810 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:06,810 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:06,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:06,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-15 02:26:06,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:06,816 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-15 02:26:06,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.140
2016-01-15 02:26:06,816 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-15 02:26:06,843 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,844 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-15 02:26:06,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:06,859 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-15 02:26:06,878 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:06,879 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:06,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-15 02:26:06,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:06,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:06,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:06,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:06,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-15 02:26:06,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:06,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:06,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:06,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-15 02:26:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1684019291_0022
2016-01-15 02:26:07,006 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:07,010 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:07,015 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:07,015 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:07,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E61974052AEC4476A043F2A91DB8AD51, ordinal: 0
2016-01-15 02:26:07,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-15 02:26:07,022 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E61974052AEC4476A043F2A91DB8AD51, mem on start (mb), free: 320, total: 379, max: 672
2016-01-15 02:26:07,023 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,024 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,026 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,027 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E61974052AEC4476A043F2A91DB8AD51, mem on close (mb), free: 320, total: 379, max: 672
2016-01-15 02:26:07,028 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1684019291_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,036 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1684019291_0022 state at FAILED
2016-01-15 02:26:07,036 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:07,036 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:07,036 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:07,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:07,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-15 02:26:07,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:07,039 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-15 02:26:07,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.122
2016-01-15 02:26:07,040 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-15 02:26:07,056 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,057 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 02:26:07,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:07,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:07,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:07,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-15 02:26:07,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:07,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:07,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:07,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-15 02:26:07,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local223732891_0023
2016-01-15 02:26:07,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:07,181 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:07,186 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:07,186 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:07,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FAE5734D6C7D441C8C5DA53E256B7EDE, ordinal: 0
2016-01-15 02:26:07,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-15 02:26:07,192 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAE5734D6C7D441C8C5DA53E256B7EDE, mem on start (mb), free: 265, total: 379, max: 672
2016-01-15 02:26:07,192 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,193 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,193 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,193 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAE5734D6C7D441C8C5DA53E256B7EDE, mem on close (mb), free: 265, total: 379, max: 672
2016-01-15 02:26:07,195 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local223732891_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
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:133)
at cascading.TestFunction.operate(TestFunction.java:86)
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:450)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
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)
2016-01-15 02:26:07,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local223732891_0023 state at FAILED
2016-01-15 02:26:07,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 02:26:07,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 02:26:07,199 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 02:26:07,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 02:26:07,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-15 02:26:07,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 02:26:07,203 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-15 02:26:07,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.115
2016-01-15 02:26:07,203 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-15 02:26:07,219 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,220 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-15 02:26:07,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:07,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:07,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:07,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-15 02:26:07,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:07,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:07,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:07,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-15 02:26:07,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1130351390_0024
2016-01-15 02:26:07,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:07,340 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:07,345 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:07,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:07,351 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E15DA84A194448C28D771E14470DE78B, ordinal: 0
2016-01-15 02:26:07,352 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,352 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-15 02:26:07,352 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E15DA84A194448C28D771E14470DE78B, mem on start (mb), free: 209, total: 379, max: 672
2016-01-15 02:26:07,355 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E15DA84A194448C28D771E14470DE78B, mem on close (mb), free: 209, total: 379, max: 672
2016-01-15 02:26:07,370 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-15 02:26:07,370 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.122
2016-01-15 02:26:07,417 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-15 02:26:07,430 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,431 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,440 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-15 02:26:07,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:07,441 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-15 02:26:07,453 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,453 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 02:26:07,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:07,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:07,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:07,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-15 02:26:07,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:07,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:07,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:07,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-15 02:26:07,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local729043254_0025
2016-01-15 02:26:07,579 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:07,582 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:07,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:07,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:07,593 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B58B945E72484C2AB83CDD6651254657, ordinal: 0
2016-01-15 02:26:07,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-15 02:26:07,594 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B58B945E72484C2AB83CDD6651254657, mem on start (mb), free: 345, total: 371, max: 672
2016-01-15 02:26:07,597 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B58B945E72484C2AB83CDD6651254657, mem on close (mb), free: 345, total: 371, max: 672
2016-01-15 02:26:07,613 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-15 02:26:07,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.132
2016-01-15 02:26:07,669 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-15 02:26:07,681 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,682 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-15 02:26:07,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:07,692 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-15 02:26:07,704 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,704 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,724 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 02:26:07,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:07,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:07,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:07,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-15 02:26:07,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:07,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:07,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:07,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-15 02:26:07,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1435067302_0026
2016-01-15 02:26:07,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:07,850 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:07,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:07,856 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:07,861 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E258ADF583374F33BA64FE24E8386D30, ordinal: 0
2016-01-15 02:26:07,861 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,862 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-15 02:26:07,862 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E258ADF583374F33BA64FE24E8386D30, mem on start (mb), free: 274, total: 371, max: 672
2016-01-15 02:26:07,865 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E258ADF583374F33BA64FE24E8386D30, mem on close (mb), free: 274, total: 371, max: 672
2016-01-15 02:26:07,878 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-15 02:26:07,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.146
2016-01-15 02:26:07,929 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-15 02:26:07,942 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:07,942 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:07,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-15 02:26:07,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:07,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:07,976 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:07,976 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:07,977 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-15 02:26:07,977 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:07,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:07,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:07,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-15 02:26:08,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1512313303_0027
2016-01-15 02:26:08,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:08,071 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:08,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:08,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:08,082 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EC731ACFE068435B842FC01DC68365E1, ordinal: 0
2016-01-15 02:26:08,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-15 02:26:08,083 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC731ACFE068435B842FC01DC68365E1, mem on start (mb), free: 211, total: 371, max: 672
2016-01-15 02:26:08,086 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC731ACFE068435B842FC01DC68365E1, mem on close (mb), free: 211, total: 371, max: 672
2016-01-15 02:26:08,101 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-15 02:26:08,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.124
2016-01-15 02:26:08,147 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-15 02:26:08,158 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:08,158 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:08,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 02:26:08,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:08,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:08,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:08,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-15 02:26:08,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1099774012_0028
2016-01-15 02:26:08,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:08,297 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:08,307 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:08,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:08,314 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F504E4DD1E7041FBAC91CEA420EC0704, ordinal: 0
2016-01-15 02:26:08,316 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-15 02:26:08,317 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F504E4DD1E7041FBAC91CEA420EC0704, mem on start (mb), free: 347, total: 362, max: 672
2016-01-15 02:26:08,320 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F504E4DD1E7041FBAC91CEA420EC0704, mem on close (mb), free: 347, total: 362, max: 672
2016-01-15 02:26:08,340 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-15 02:26:08,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.141
2016-01-15 02:26:08,384 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-15 02:26:08,397 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:08,398 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:08,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 02:26:08,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:08,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:08,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:08,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-15 02:26:08,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local2119069825_0029
2016-01-15 02:26:08,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:08,531 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:08,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:08,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:08,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E0EA7E89347346DDAB805BAB11BE5F02, ordinal: 0
2016-01-15 02:26:08,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-15 02:26:08,541 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EA7E89347346DDAB805BAB11BE5F02, mem on start (mb), free: 287, total: 362, max: 672
2016-01-15 02:26:08,544 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EA7E89347346DDAB805BAB11BE5F02, mem on close (mb), free: 287, total: 362, max: 672
2016-01-15 02:26:08,562 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-15 02:26:08,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.137
2016-01-15 02:26:08,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-15 02:26:08,614 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:08,615 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:08,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 02:26:08,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:08,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:08,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-15 02:26:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:08,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:08,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-15 02:26:08,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local642427874_0030
2016-01-15 02:26:08,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:08,739 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:08,744 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:08,745 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:08,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B857616631884B499B9B3E3E4F46A0F5, ordinal: 0
2016-01-15 02:26:08,751 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,751 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-15 02:26:08,751 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B857616631884B499B9B3E3E4F46A0F5, mem on start (mb), free: 228, total: 362, max: 672
2016-01-15 02:26:08,753 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B857616631884B499B9B3E3E4F46A0F5, mem on close (mb), free: 228, total: 362, max: 672
2016-01-15 02:26:08,769 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-15 02:26:08,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.128
2016-01-15 02:26:08,816 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-15 02:26:08,834 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:08,835 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:08,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-15 02:26:08,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 02:26:08,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 02:26:08,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 02:26:08,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-15 02:26:08,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-15 02:26:08,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-15 02:26:08,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-15 02:26:08,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-15 02:26:08,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local556164769_0031
2016-01-15 02:26:08,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 02:26:08,966 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-01-15 02:26:08,971 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 02:26:08,971 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 02:26:08,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C28D5FE88EA7480A8272AFB0B9416F08, ordinal: 0
2016-01-15 02:26:08,977 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-01-15 02:26:08,977 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-15 02:26:08,977 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C28D5FE88EA7480A8272AFB0B9416F08, mem on start (mb), free: 168, total: 362, max: 672
2016-01-15 02:26:08,979 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C28D5FE88EA7480A8272AFB0B9416F08, mem on close (mb), free: 168, total: 362, max: 672
2016-01-15 02:26:08,997 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-15 02:26:08,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.132
2016-01-15 02:26:09,038 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-15 02:26:09,049 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 02:26:09,049 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 02:26:09,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-15 02:26:09,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 02:26:09,058 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'