2016-05-18 05:48:40,104 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:48:40,127 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop
2016-05-18 05:48:40,623 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 05:48:40,849 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:48:40,926 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:40,929 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:41,053 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: E54E9AEF95EF497BA651FCE7A0A88618
2016-05-18 05:48:41,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.092
2016-05-18 05:48:41,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:41,188 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:41,360 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 05:48:41,362 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:41,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:41,363 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 05:48:41,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:41,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:41,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:41,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-18 05:48:41,402 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 05:48:41,464 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 05:48:41,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1412845690_0001
2016-05-18 05:48:41,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:41,801 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:41,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:41,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:41,837 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5A39010F8C74D9EA1D53954153B93BC, ordinal: 0
2016-05-18 05:48:41,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:41,881 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 05:48:41,882 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5A39010F8C74D9EA1D53954153B93BC, mem on start (mb), free: 183, total: 223, max: 672
2016-05-18 05:48:41,895 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5A39010F8C74D9EA1D53954153B93BC, mem on close (mb), free: 183, total: 223, max: 672
2016-05-18 05:48:41,919 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-18 05:48:41,921 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.555
2016-05-18 05:48:41,965 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-18 05:48:41,985 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:41,986 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:42,048 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2016-05-18 05:48:42,050 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:42,050 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:42,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:42,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,068 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 05:48:42,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:42,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:42,069 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:42,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-18 05:48:42,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local586034521_0002
2016-05-18 05:48:42,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:42,179 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:42,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:42,189 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:42,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA25296FCE9044BCA2F30DC8E9B01BAD, ordinal: 0
2016-05-18 05:48:42,233 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,235 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 05:48:42,236 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA25296FCE9044BCA2F30DC8E9B01BAD, mem on start (mb), free: 168, total: 223, max: 672
2016-05-18 05:48:42,244 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA25296FCE9044BCA2F30DC8E9B01BAD, mem on close (mb), free: 168, total: 223, max: 672
2016-05-18 05:48:42,279 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-18 05:48:42,279 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.211
2016-05-18 05:48:42,348 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-18 05:48:42,375 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:42,376 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:42,446 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-18 05:48:42,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:42,449 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:42,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:42,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 05:48:42,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:42,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:42,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:42,471 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-18 05:48:42,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1343161082_0003
2016-05-18 05:48:42,559 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:42,564 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:42,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:42,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:42,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F0A2A95E7429481E92C3B4631576FDF8, ordinal: 0
2016-05-18 05:48:42,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 05:48:42,583 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0A2A95E7429481E92C3B4631576FDF8, mem on start (mb), free: 209, total: 223, max: 672
2016-05-18 05:48:42,586 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F0A2A95E7429481E92C3B4631576FDF8, mem on close (mb), free: 209, total: 223, max: 672
2016-05-18 05:48:42,601 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-18 05:48:42,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.133
2016-05-18 05:48:42,624 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-18 05:48:42,633 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:42,634 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:42,678 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 05:48:42,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:42,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:42,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 05:48:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:42,695 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:42,695 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:42,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-18 05:48:42,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1100061737_0004
2016-05-18 05:48:42,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:42,750 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:42,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:42,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:42,767 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D3EBD5CDB23D42D6AE68E6055E892593, ordinal: 0
2016-05-18 05:48:42,768 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,769 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 05:48:42,769 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3EBD5CDB23D42D6AE68E6055E892593, mem on start (mb), free: 196, total: 223, max: 672
2016-05-18 05:48:42,772 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3EBD5CDB23D42D6AE68E6055E892593, mem on close (mb), free: 196, total: 223, max: 672
2016-05-18 05:48:42,787 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-18 05:48:42,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.094
2016-05-18 05:48:42,808 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-18 05:48:42,817 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:42,817 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:42,857 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 05:48:42,858 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:42,859 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:42,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:42,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 05:48:42,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:42,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:42,873 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:42,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-18 05:48:42,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local456097268_0005
2016-05-18 05:48:42,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:42,922 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:42,926 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:42,926 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:42,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE3B7523D1A54BED9082F29340447322, ordinal: 0
2016-05-18 05:48:42,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:42,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 05:48:42,940 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE3B7523D1A54BED9082F29340447322, mem on start (mb), free: 183, total: 223, max: 672
2016-05-18 05:48:42,943 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE3B7523D1A54BED9082F29340447322, mem on close (mb), free: 183, total: 223, max: 672
2016-05-18 05:48:42,961 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-18 05:48:42,961 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.091
2016-05-18 05:48:42,981 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-18 05:48:42,989 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:42,990 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 05:48:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 05:48:43,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-18 05:48:43,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local34074086_0006
2016-05-18 05:48:43,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,081 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B07A8E8B149A416A9377566D47148861, ordinal: 0
2016-05-18 05:48:43,096 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,096 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 05:48:43,097 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B07A8E8B149A416A9377566D47148861, mem on start (mb), free: 171, total: 223, max: 672
2016-05-18 05:48:43,099 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B07A8E8B149A416A9377566D47148861, mem on close (mb), free: 171, total: 223, max: 672
2016-05-18 05:48:43,108 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-18 05:48:43,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.069
2016-05-18 05:48:43,126 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-18 05:48:43,133 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,133 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 05:48:43,152 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:43,152 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-18 05:48:43,160 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,160 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,192 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 05:48:43,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 05:48:43,204 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-18 05:48:43,241 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local279196305_0007
2016-05-18 05:48:43,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,246 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,259 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ECD3868FF5C447F6B40860773F106AEE, ordinal: 0
2016-05-18 05:48:43,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 05:48:43,260 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ECD3868FF5C447F6B40860773F106AEE, mem on start (mb), free: 156, total: 223, max: 672
2016-05-18 05:48:43,262 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ECD3868FF5C447F6B40860773F106AEE, mem on close (mb), free: 156, total: 223, max: 672
2016-05-18 05:48:43,281 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-18 05:48:43,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.077
2016-05-18 05:48:43,344 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-18 05:48:43,351 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,352 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,386 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 05:48:43,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,388 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 05:48:43,400 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-18 05:48:43,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1363510817_0008
2016-05-18 05:48:43,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,463 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D275026DD38A44908378803697405495, ordinal: 0
2016-05-18 05:48:43,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,480 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 05:48:43,480 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D275026DD38A44908378803697405495, mem on start (mb), free: 260, total: 281, max: 672
2016-05-18 05:48:43,482 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D275026DD38A44908378803697405495, mem on close (mb), free: 260, total: 281, max: 672
2016-05-18 05:48:43,493 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-18 05:48:43,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.094
2016-05-18 05:48:43,515 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-18 05:48:43,525 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,526 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,565 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 05:48:43,566 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,567 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 05:48:43,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,578 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,579 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 05:48:43,609 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local470251196_0009
2016-05-18 05:48:43,610 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,615 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,628 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3259D73EAB2459786DECB194DF9CACF, ordinal: 0
2016-05-18 05:48:43,628 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 05:48:43,630 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3259D73EAB2459786DECB194DF9CACF, mem on start (mb), free: 245, total: 281, max: 672
2016-05-18 05:48:43,634 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3259D73EAB2459786DECB194DF9CACF, mem on close (mb), free: 245, total: 281, max: 672
2016-05-18 05:48:43,652 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-18 05:48:43,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.075
2016-05-18 05:48:43,668 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 05:48:43,676 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,677 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 05:48:43,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,725 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 05:48:43,726 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 05:48:43,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1550304226_0010
2016-05-18 05:48:43,756 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,760 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,764 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,764 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,772 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F97EDBA0F37F43BA9CF054DB8C6450C2, ordinal: 0
2016-05-18 05:48:43,773 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,774 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 05:48:43,774 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F97EDBA0F37F43BA9CF054DB8C6450C2, mem on start (mb), free: 231, total: 281, max: 672
2016-05-18 05:48:43,776 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,781 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,784 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,786 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F97EDBA0F37F43BA9CF054DB8C6450C2, mem on close (mb), free: 230, total: 281, max: 672
2016-05-18 05:48:43,787 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1550304226_0010
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,797 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1550304226_0010 state at FAILED
2016-05-18 05:48:43,797 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:43,799 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:43,799 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:43,799 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:43,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 05:48:43,800 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:43,800 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-18 05:48:43,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.075
2016-05-18 05:48:43,801 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-18 05:48:43,810 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,810 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.018
2016-05-18 05:48:43,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:43,833 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-18 05:48:43,842 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,842 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,881 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 05:48:43,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:43,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:43,896 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 05:48:43,897 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:43,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:43,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:43,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 05:48:43,925 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local20321708_0011
2016-05-18 05:48:43,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:43,930 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:43,934 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:43,934 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:43,942 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB53FD6F0CB84266B2DF2E95AF4D17DF, ordinal: 0
2016-05-18 05:48:43,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:43,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 05:48:43,943 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB53FD6F0CB84266B2DF2E95AF4D17DF, mem on start (mb), free: 216, total: 281, max: 672
2016-05-18 05:48:43,945 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,946 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,950 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,952 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB53FD6F0CB84266B2DF2E95AF4D17DF, mem on close (mb), free: 216, total: 281, max: 672
2016-05-18 05:48:43,953 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local20321708_0011
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:43,957 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local20321708_0011 state at FAILED
2016-05-18 05:48:43,957 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:43,957 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:43,957 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:43,957 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:43,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 05:48:43,958 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:43,958 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-18 05:48:43,959 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.062
2016-05-18 05:48:43,959 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-18 05:48:43,967 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:43,968 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:43,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:48:43,996 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:43,996 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 05:48:44,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 05:48:44,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local969096581_0012
2016-05-18 05:48:44,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,049 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,055 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,068 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B8891962FCD44920B799EC65181C2DCE, ordinal: 0
2016-05-18 05:48:44,069 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,070 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 05:48:44,070 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8891962FCD44920B799EC65181C2DCE, mem on start (mb), free: 205, total: 281, max: 672
2016-05-18 05:48:44,071 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:44,084 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:44,095 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:44,099 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8891962FCD44920B799EC65181C2DCE, mem on close (mb), free: 204, total: 281, max: 672
2016-05-18 05:48:44,100 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local969096581_0012
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:44,105 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local969096581_0012 state at FAILED
2016-05-18 05:48:44,105 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:44,106 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:44,106 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:44,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:44,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 05:48:44,107 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:44,107 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-18 05:48:44,108 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.102
2016-05-18 05:48:44,108 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-18 05:48:44,115 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,116 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 05:48:44,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:44,129 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-18 05:48:44,137 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,137 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 05:48:44,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,164 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 05:48:44,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,175 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-18 05:48:44,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local370733895_0013
2016-05-18 05:48:44,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,215 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CABFDFB7099E4610ABA1074E4BA47C51, ordinal: 0
2016-05-18 05:48:44,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 05:48:44,229 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CABFDFB7099E4610ABA1074E4BA47C51, mem on start (mb), free: 190, total: 281, max: 672
2016-05-18 05:48:44,232 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CABFDFB7099E4610ABA1074E4BA47C51, mem on close (mb), free: 190, total: 281, max: 672
2016-05-18 05:48:44,253 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-18 05:48:44,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.080
2016-05-18 05:48:44,272 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-18 05:48:44,281 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,281 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 05:48:44,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:44,296 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-18 05:48:44,304 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,304 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 05:48:44,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 05:48:44,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,343 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-18 05:48:44,372 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1238653540_0014
2016-05-18 05:48:44,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,378 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB5B62FB88FB4A449A2BE0D1B7522BDE, ordinal: 0
2016-05-18 05:48:44,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 05:48:44,391 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB5B62FB88FB4A449A2BE0D1B7522BDE, mem on start (mb), free: 174, total: 281, max: 672
2016-05-18 05:48:44,394 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB5B62FB88FB4A449A2BE0D1B7522BDE, mem on close (mb), free: 174, total: 281, max: 672
2016-05-18 05:48:44,405 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-18 05:48:44,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.065
2016-05-18 05:48:44,422 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-18 05:48:44,430 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,430 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,457 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:48:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,466 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 05:48:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,468 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-18 05:48:44,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1230839807_0015
2016-05-18 05:48:44,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,501 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,504 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,512 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E367803C2FF443AAB980222D3637443F, ordinal: 0
2016-05-18 05:48:44,512 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 05:48:44,513 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E367803C2FF443AAB980222D3637443F, mem on start (mb), free: 159, total: 281, max: 672
2016-05-18 05:48:44,515 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E367803C2FF443AAB980222D3637443F, mem on close (mb), free: 159, total: 281, max: 672
2016-05-18 05:48:44,529 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-18 05:48:44,530 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.063
2016-05-18 05:48:44,570 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-18 05:48:44,577 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,577 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,600 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 05:48:44,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,601 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,612 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 05:48:44,613 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,615 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-18 05:48:44,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1922115148_0016
2016-05-18 05:48:44,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,645 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,648 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,649 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,656 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C7733B0CBDCD4EA597E7F1C5E8893E2A, ordinal: 0
2016-05-18 05:48:44,657 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,657 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 05:48:44,657 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7733B0CBDCD4EA597E7F1C5E8893E2A, mem on start (mb), free: 260, total: 281, max: 672
2016-05-18 05:48:44,659 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7733B0CBDCD4EA597E7F1C5E8893E2A, mem on close (mb), free: 260, total: 281, max: 672
2016-05-18 05:48:44,672 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-18 05:48:44,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.060
2016-05-18 05:48:44,687 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-18 05:48:44,694 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,695 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 05:48:44,719 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,720 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,728 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 05:48:44,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,729 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,731 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-18 05:48:44,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1970336103_0017
2016-05-18 05:48:44,755 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,759 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,762 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,763 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E56DF15FD3D542ED918E6D00DCA39906, ordinal: 0
2016-05-18 05:48:44,771 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,771 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 05:48:44,771 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E56DF15FD3D542ED918E6D00DCA39906, mem on start (mb), free: 246, total: 281, max: 672
2016-05-18 05:48:44,774 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E56DF15FD3D542ED918E6D00DCA39906, mem on close (mb), free: 246, total: 281, max: 672
2016-05-18 05:48:44,788 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-18 05:48:44,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.060
2016-05-18 05:48:44,803 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-18 05:48:44,810 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,810 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,832 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:48:44,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,833 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,842 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 05:48:44,843 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,844 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,846 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-18 05:48:44,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1533779007_0018
2016-05-18 05:48:44,869 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:44,873 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:44,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:44,876 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:44,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9F50230DBFE4933998B43DC933F1A51, ordinal: 0
2016-05-18 05:48:44,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,885 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 05:48:44,885 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9F50230DBFE4933998B43DC933F1A51, mem on start (mb), free: 231, total: 281, max: 672
2016-05-18 05:48:44,888 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9F50230DBFE4933998B43DC933F1A51, mem on close (mb), free: 231, total: 281, max: 672
2016-05-18 05:48:44,902 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-18 05:48:44,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.060
2016-05-18 05:48:44,916 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-18 05:48:44,922 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,923 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 05:48:44,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:44,933 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-18 05:48:44,942 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:44,943 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:44,972 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 05:48:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:44,973 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:44,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:44,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:44,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 05:48:44,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:44,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:44,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:44,984 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-18 05:48:45,009 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local663798273_0019
2016-05-18 05:48:45,010 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,013 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,022 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4E28133008F4603B50A3B4C943C485F, ordinal: 0
2016-05-18 05:48:45,023 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,023 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 05:48:45,023 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4E28133008F4603B50A3B4C943C485F, mem on start (mb), free: 214, total: 281, max: 672
2016-05-18 05:48:45,025 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4E28133008F4603B50A3B4C943C485F, mem on close (mb), free: 214, total: 281, max: 672
2016-05-18 05:48:45,042 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-18 05:48:45,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.060
2016-05-18 05:48:45,055 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-18 05:48:45,061 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,061 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:48:45,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 05:48:45,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,090 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-18 05:48:45,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1780059438_0020
2016-05-18 05:48:45,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,122 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,126 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DF7C62DC57AE45479E452CFCE6FCD396, ordinal: 0
2016-05-18 05:48:45,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 05:48:45,136 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF7C62DC57AE45479E452CFCE6FCD396, mem on start (mb), free: 200, total: 281, max: 672
2016-05-18 05:48:45,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF7C62DC57AE45479E452CFCE6FCD396, mem on close (mb), free: 200, total: 281, max: 672
2016-05-18 05:48:45,150 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-18 05:48:45,151 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.061
2016-05-18 05:48:45,164 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-18 05:48:45,170 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,171 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 05:48:45,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,199 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 05:48:45,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,200 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,202 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 05:48:45,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local763479124_0021
2016-05-18 05:48:45,225 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,230 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,244 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5B3931A5AB74AB582666A1C2341F4A9, ordinal: 0
2016-05-18 05:48:45,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,245 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 05:48:45,245 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B3931A5AB74AB582666A1C2341F4A9, mem on start (mb), free: 185, total: 281, max: 672
2016-05-18 05:48:45,246 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,248 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,258 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,258 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B3931A5AB74AB582666A1C2341F4A9, mem on close (mb), free: 184, total: 281, max: 672
2016-05-18 05:48:45,259 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local763479124_0021
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,265 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local763479124_0021 state at FAILED
2016-05-18 05:48:45,265 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:45,265 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:45,265 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:45,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:45,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 05:48:45,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:45,267 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-18 05:48:45,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.067
2016-05-18 05:48:45,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-18 05:48:45,276 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,276 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 05:48:45,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:45,295 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-18 05:48:45,301 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,301 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 05:48:45,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,326 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,338 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 05:48:45,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 05:48:45,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1397634783_0022
2016-05-18 05:48:45,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,369 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A99B81CF1B544B5B87337B75C0CFB891, ordinal: 0
2016-05-18 05:48:45,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 05:48:45,379 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A99B81CF1B544B5B87337B75C0CFB891, mem on start (mb), free: 171, total: 281, max: 672
2016-05-18 05:48:45,380 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,383 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,389 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,392 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A99B81CF1B544B5B87337B75C0CFB891, mem on close (mb), free: 170, total: 281, max: 672
2016-05-18 05:48:45,393 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1397634783_0022
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,395 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1397634783_0022 state at FAILED
2016-05-18 05:48:45,395 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:45,395 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:45,395 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:45,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:45,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 05:48:45,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:45,396 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-18 05:48:45,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.059
2016-05-18 05:48:45,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-18 05:48:45,404 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,404 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 05:48:45,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 05:48:45,432 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,433 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,436 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 05:48:45,462 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1692148324_0023
2016-05-18 05:48:45,463 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,466 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2D76FB1B0494143ADC73B05928CA09D, ordinal: 0
2016-05-18 05:48:45,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,475 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 05:48:45,475 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2D76FB1B0494143ADC73B05928CA09D, mem on start (mb), free: 159, total: 281, max: 672
2016-05-18 05:48:45,475 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,476 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,476 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,477 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2D76FB1B0494143ADC73B05928CA09D, mem on close (mb), free: 158, total: 281, max: 672
2016-05-18 05:48:45,478 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1692148324_0023
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
at cascading.TestFunction.operate(TestFunction.java:104)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
at cascading.TestFunction.operate(TestFunction.java:101)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
... 18 more
2016-05-18 05:48:45,483 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1692148324_0023 state at FAILED
2016-05-18 05:48:45,483 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 05:48:45,484 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 05:48:45,484 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 05:48:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 05:48:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 05:48:45,484 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 05:48:45,485 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-18 05:48:45,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.053
2016-05-18 05:48:45,486 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-18 05:48:45,495 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,495 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,541 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:48:45,541 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,541 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,548 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 05:48:45,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,549 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,550 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-18 05:48:45,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1523880095_0024
2016-05-18 05:48:45,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,575 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,578 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,578 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AA3586233D84454EA051FB8279794DAC, ordinal: 0
2016-05-18 05:48:45,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 05:48:45,585 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA3586233D84454EA051FB8279794DAC, mem on start (mb), free: 374, total: 396, max: 672
2016-05-18 05:48:45,588 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA3586233D84454EA051FB8279794DAC, mem on close (mb), free: 374, total: 396, max: 672
2016-05-18 05:48:45,604 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-18 05:48:45,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.056
2016-05-18 05:48:45,617 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-18 05:48:45,623 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,624 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,633 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 05:48:45,634 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:45,634 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-18 05:48:45,640 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,641 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,662 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 05:48:45,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,663 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 05:48:45,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-18 05:48:45,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1079184661_0025
2016-05-18 05:48:45,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,696 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D734AABD2C23457D899E48521041A10A, ordinal: 0
2016-05-18 05:48:45,705 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,705 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 05:48:45,705 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D734AABD2C23457D899E48521041A10A, mem on start (mb), free: 356, total: 396, max: 672
2016-05-18 05:48:45,707 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D734AABD2C23457D899E48521041A10A, mem on close (mb), free: 356, total: 396, max: 672
2016-05-18 05:48:45,715 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-18 05:48:45,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.045
2016-05-18 05:48:45,728 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-18 05:48:45,733 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,733 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 05:48:45,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:45,744 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-18 05:48:45,749 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,749 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:48:45,765 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,766 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,775 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-18 05:48:45,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1453968749_0026
2016-05-18 05:48:45,794 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,798 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,803 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,803 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B06E11F2F9514E81A97D2EBE67DD2FED, ordinal: 0
2016-05-18 05:48:45,810 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,811 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 05:48:45,811 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B06E11F2F9514E81A97D2EBE67DD2FED, mem on start (mb), free: 339, total: 396, max: 672
2016-05-18 05:48:45,814 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B06E11F2F9514E81A97D2EBE67DD2FED, mem on close (mb), free: 339, total: 396, max: 672
2016-05-18 05:48:45,826 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-18 05:48:45,827 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.054
2016-05-18 05:48:45,840 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-18 05:48:45,846 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,847 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 05:48:45,867 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,868 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,874 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 05:48:45,875 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,876 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,877 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-18 05:48:45,898 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local509006476_0027
2016-05-18 05:48:45,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:45,903 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:45,906 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:45,906 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:45,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE441E10FA4B4D52BD68B5FC9B63C104, ordinal: 0
2016-05-18 05:48:45,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 05:48:45,913 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE441E10FA4B4D52BD68B5FC9B63C104, mem on start (mb), free: 325, total: 396, max: 672
2016-05-18 05:48:45,916 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE441E10FA4B4D52BD68B5FC9B63C104, mem on close (mb), free: 325, total: 396, max: 672
2016-05-18 05:48:45,931 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-18 05:48:45,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.057
2016-05-18 05:48:45,945 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-18 05:48:45,951 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:45,952 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:45,969 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:48:45,970 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:45,970 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:45,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:45,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:45,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 05:48:45,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:45,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:45,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:45,980 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-18 05:48:46,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local195609396_0028
2016-05-18 05:48:46,001 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:46,005 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:46,008 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:46,008 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:46,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C7DC40AA9A5C4905B4DC15EF4BA1DFBA, ordinal: 0
2016-05-18 05:48:46,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,015 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 05:48:46,015 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7DC40AA9A5C4905B4DC15EF4BA1DFBA, mem on start (mb), free: 309, total: 396, max: 672
2016-05-18 05:48:46,018 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7DC40AA9A5C4905B4DC15EF4BA1DFBA, mem on close (mb), free: 309, total: 396, max: 672
2016-05-18 05:48:46,033 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-18 05:48:46,034 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.056
2016-05-18 05:48:46,047 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-18 05:48:46,053 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:46,054 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:46,070 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 05:48:46,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:46,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:46,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:46,078 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,078 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 05:48:46,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:46,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:46,080 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:46,081 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-18 05:48:46,101 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local477537866_0029
2016-05-18 05:48:46,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:46,105 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:46,109 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:46,109 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:46,114 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A8306D486298450EB941EFD891171AE3, ordinal: 0
2016-05-18 05:48:46,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 05:48:46,116 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8306D486298450EB941EFD891171AE3, mem on start (mb), free: 295, total: 396, max: 672
2016-05-18 05:48:46,118 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8306D486298450EB941EFD891171AE3, mem on close (mb), free: 295, total: 396, max: 672
2016-05-18 05:48:46,134 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-18 05:48:46,134 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.057
2016-05-18 05:48:46,148 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-18 05:48:46,153 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:46,154 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:46,173 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 05:48:46,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:46,174 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:46,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:46,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 05:48:46,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:46,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:46,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:46,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-18 05:48:46,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local905005748_0030
2016-05-18 05:48:46,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:46,218 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:46,220 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:46,220 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:46,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA698DA7B7824E00A99AC1F4B5EC3984, ordinal: 0
2016-05-18 05:48:46,226 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,226 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 05:48:46,226 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA698DA7B7824E00A99AC1F4B5EC3984, mem on start (mb), free: 281, total: 396, max: 672
2016-05-18 05:48:46,228 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA698DA7B7824E00A99AC1F4B5EC3984, mem on close (mb), free: 281, total: 396, max: 672
2016-05-18 05:48:46,234 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-18 05:48:46,235 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.055
2016-05-18 05:48:46,253 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-18 05:48:46,261 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:46,262 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:46,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 05:48:46,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:48:46,292 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 05:48:46,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 05:48:46,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 05:48:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-18 05:48:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-18 05:48:46,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-18 05:48:46,304 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 05:48:46,334 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local629556948_0031
2016-05-18 05:48:46,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 05:48:46,339 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-05-18 05:48:46,341 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:48:46,341 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:48:46,346 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CFFDE45F26854AAE9DDF0CAF37D229B9, ordinal: 0
2016-05-18 05:48:46,347 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-05-18 05:48:46,347 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 05:48:46,347 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFFDE45F26854AAE9DDF0CAF37D229B9, mem on start (mb), free: 265, total: 396, max: 672
2016-05-18 05:48:46,349 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFFDE45F26854AAE9DDF0CAF37D229B9, mem on close (mb), free: 265, total: 396, max: 672
2016-05-18 05:48:46,357 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-18 05:48:46,358 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.057
2016-05-18 05:48:46,370 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 05:48:46,375 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:48:46,376 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-18 05:48:46,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 05:48:46,384 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 05:48:46,385 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'