2016-05-17 23:23:57,030 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 23:23:57,056 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop
2016-05-17 23:23:57,554 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 23:23:57,783 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 23:23:57,853 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:23:57,854 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-17 23:23:57,976 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: B1076DD4BEAA465A8D93B9D129D2EE47
2016-05-17 23:23:58,106 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-17 23:23:58,109 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:23:58,109 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-17 23:23:58,287 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 23:23:58,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:23:58,290 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:23:58,290 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-17 23:23:58,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:23:58,291 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:23:58,293 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:23:58,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-17 23:23:58,338 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 23:23:58,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0001
2016-05-17 23:23:58,602 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:23:58,664 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:23:58,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:23:58,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:23:58,690 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F7DFAA37037C4E009A7EFD54395BBA9E, ordinal: 0
2016-05-17 23:23:58,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:23:58,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-17 23:23:58,732 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7DFAA37037C4E009A7EFD54395BBA9E, mem on start (mb), free: 242, total: 281, max: 672
2016-05-17 23:23:58,745 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7DFAA37037C4E009A7EFD54395BBA9E, mem on close (mb), free: 241, total: 281, max: 672
2016-05-17 23:24:01,650 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-17 23:24:01,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.360
2016-05-17 23:24:01,697 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-17 23:24:01,716 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:01,717 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-17 23:24:01,790 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-05-17 23:24:01,792 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:01,792 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-17 23:24:01,809 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:01,809 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:01,810 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-17 23:24:01,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:01,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:01,811 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:01,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-17 23:24:01,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0002
2016-05-17 23:24:01,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:01,887 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:01,892 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:01,892 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:01,905 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA185A64958C4DEABA868649F9D0E528, ordinal: 0
2016-05-17 23:24:01,906 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:01,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-17 23:24:01,907 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA185A64958C4DEABA868649F9D0E528, mem on start (mb), free: 230, total: 281, max: 672
2016-05-17 23:24:01,910 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA185A64958C4DEABA868649F9D0E528, mem on close (mb), free: 230, total: 281, max: 672
2016-05-17 23:24:04,898 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-17 23:24:04,899 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.089
2016-05-17 23:24:04,930 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-17 23:24:04,949 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:04,950 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-17 23:24:05,017 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-17 23:24:05,019 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:05,020 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-17 23:24:05,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:05,041 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:05,041 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-17 23:24:05,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:05,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:05,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:05,044 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-17 23:24:05,134 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0003
2016-05-17 23:24:05,134 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:05,140 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:05,147 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:05,147 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:05,163 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A691561E53BB49BAB43C6DBD8EB6BBE8, ordinal: 0
2016-05-17 23:24:05,165 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:05,165 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-17 23:24:05,165 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A691561E53BB49BAB43C6DBD8EB6BBE8, mem on start (mb), free: 218, total: 281, max: 672
2016-05-17 23:24:05,169 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A691561E53BB49BAB43C6DBD8EB6BBE8, mem on close (mb), free: 218, total: 281, max: 672
2016-05-17 23:24:08,149 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-17 23:24:08,150 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.109
2016-05-17 23:24:08,171 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-17 23:24:08,180 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:08,181 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-17 23:24:08,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-05-17 23:24:08,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:08,229 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-17 23:24:08,243 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:08,243 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:08,244 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-17 23:24:08,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:08,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:08,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:08,246 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-17 23:24:08,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0004
2016-05-17 23:24:08,288 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:08,293 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:08,298 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:08,298 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:08,307 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5FF96622EB14D79AEEE74F4D30A42DD, ordinal: 0
2016-05-17 23:24:08,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:08,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-17 23:24:08,308 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5FF96622EB14D79AEEE74F4D30A42DD, mem on start (mb), free: 206, total: 281, max: 672
2016-05-17 23:24:08,311 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5FF96622EB14D79AEEE74F4D30A42DD, mem on close (mb), free: 206, total: 281, max: 672
2016-05-17 23:24:11,304 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-17 23:24:11,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.061
2016-05-17 23:24:11,327 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-17 23:24:11,339 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:11,339 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-17 23:24:11,377 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-17 23:24:11,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:11,378 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-17 23:24:11,390 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:11,390 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:11,391 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-17 23:24:11,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:11,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:11,392 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:11,393 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-17 23:24:11,433 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0005
2016-05-17 23:24:11,434 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:11,438 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:11,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:11,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:11,454 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADDA594BA14544CB8E0E63E9F98C98A1, ordinal: 0
2016-05-17 23:24:11,456 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:11,456 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-17 23:24:11,457 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADDA594BA14544CB8E0E63E9F98C98A1, mem on start (mb), free: 195, total: 281, max: 672
2016-05-17 23:24:11,460 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADDA594BA14544CB8E0E63E9F98C98A1, mem on close (mb), free: 195, total: 281, max: 672
2016-05-17 23:24:14,449 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-17 23:24:14,450 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.058
2016-05-17 23:24:14,469 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-17 23:24:14,478 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:14,478 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-17 23:24:14,516 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-17 23:24:14,518 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:14,518 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-17 23:24:14,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:14,531 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:14,532 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-17 23:24:14,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:14,532 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:14,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:14,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-17 23:24:14,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0006
2016-05-17 23:24:14,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:14,579 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:14,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:14,584 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:14,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E86CDD4EF1A04A30BF72A4533B6F0ACB, ordinal: 0
2016-05-17 23:24:14,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:14,596 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-17 23:24:14,596 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E86CDD4EF1A04A30BF72A4533B6F0ACB, mem on start (mb), free: 185, total: 281, max: 672
2016-05-17 23:24:14,599 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E86CDD4EF1A04A30BF72A4533B6F0ACB, mem on close (mb), free: 185, total: 281, max: 672
2016-05-17 23:24:17,589 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-17 23:24:17,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.058
2016-05-17 23:24:17,609 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-17 23:24:17,617 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:17,618 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-17 23:24:17,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.016
2016-05-17 23:24:17,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:17,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-17 23:24:17,648 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:17,649 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-17 23:24:17,685 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 23:24:17,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:17,686 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 23:24:17,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:17,698 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:17,698 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-17 23:24:17,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:17,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:17,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:17,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-17 23:24:17,738 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0007
2016-05-17 23:24:17,741 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:17,745 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:17,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:17,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:17,759 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C7338E090AC74B83925A184F09D5930E, ordinal: 0
2016-05-17 23:24:17,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:17,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-17 23:24:17,761 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7338E090AC74B83925A184F09D5930E, mem on start (mb), free: 171, total: 281, max: 672
2016-05-17 23:24:17,764 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C7338E090AC74B83925A184F09D5930E, mem on close (mb), free: 171, total: 281, max: 672
2016-05-17 23:24:20,756 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-17 23:24:20,757 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.058
2016-05-17 23:24:20,777 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-17 23:24:20,786 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:20,787 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-17 23:24:20,821 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 23:24:20,822 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:20,822 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-17 23:24:20,835 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:20,835 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:20,835 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-17 23:24:20,836 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:20,836 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:20,836 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:20,837 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-17 23:24:20,870 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0008
2016-05-17 23:24:20,871 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:20,891 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:20,899 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:20,900 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:20,908 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B6145D3E6A3F4CC2806620C39381C662, ordinal: 0
2016-05-17 23:24:20,908 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:20,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-17 23:24:20,909 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6145D3E6A3F4CC2806620C39381C662, mem on start (mb), free: 270, total: 281, max: 672
2016-05-17 23:24:20,911 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6145D3E6A3F4CC2806620C39381C662, mem on close (mb), free: 270, total: 281, max: 672
2016-05-17 23:24:23,894 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-17 23:24:23,894 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.058
2016-05-17 23:24:23,914 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-17 23:24:23,923 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:23,924 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-17 23:24:23,964 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 23:24:23,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:23,966 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-17 23:24:23,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:23,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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:23,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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-17 23:24:23,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:23,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:23,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:23,978 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-17 23:24:24,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0009
2016-05-17 23:24:24,016 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:24,020 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:24,025 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:24,025 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:24,037 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB99DD64B9EF47E3A2AA6CED51380D6E, ordinal: 0
2016-05-17 23:24:24,038 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:24,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-17 23:24:24,039 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB99DD64B9EF47E3A2AA6CED51380D6E, mem on start (mb), free: 257, total: 281, max: 672
2016-05-17 23:24:24,042 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB99DD64B9EF47E3A2AA6CED51380D6E, mem on close (mb), free: 257, total: 281, max: 672
2016-05-17 23:24:27,031 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-17 23:24:27,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.055
2016-05-17 23:24:27,046 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-17 23:24:27,052 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,053 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-17 23:24:27,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-17 23:24:27,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:27,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-17 23:24:27,093 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:27,093 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,093 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-17 23:24:27,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:27,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:27,094 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:27,095 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-17 23:24:27,119 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0010
2016-05-17 23:24:27,121 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:27,124 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:27,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:27,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:27,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CEF61260E7ED41CD91116F78EE3D86D4, ordinal: 0
2016-05-17 23:24:27,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-17 23:24:27,137 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEF61260E7ED41CD91116F78EE3D86D4, mem on start (mb), free: 247, total: 281, max: 672
2016-05-17 23:24:27,140 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,142 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,147 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,150 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEF61260E7ED41CD91116F78EE3D86D4, mem on close (mb), free: 247, total: 281, max: 672
2016-05-17 23:24:27,151 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,154 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0010 state at FAILED
2016-05-17 23:24:27,155 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:27,156 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:27,156 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:27,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:27,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-17 23:24:27,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:27,158 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-17 23:24:27,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.064
2016-05-17 23:24:27,158 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-17 23:24:27,167 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,167 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-17 23:24:27,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-05-17 23:24:27,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:27,181 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-17 23:24:27,187 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,187 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-17 23:24:27,219 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 23:24:27,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:27,220 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-17 23:24:27,229 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:27,229 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,230 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-17 23:24:27,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:27,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:27,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:27,231 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-17 23:24:27,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0011
2016-05-17 23:24:27,257 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:27,260 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:27,263 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:27,264 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:27,271 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC83FC56A06D4127A6F716741AD47D60, ordinal: 0
2016-05-17 23:24:27,271 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,272 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-17 23:24:27,272 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC83FC56A06D4127A6F716741AD47D60, mem on start (mb), free: 236, total: 281, max: 672
2016-05-17 23:24:27,272 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,274 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,276 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,278 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC83FC56A06D4127A6F716741AD47D60, mem on close (mb), free: 236, total: 281, max: 672
2016-05-17 23:24:27,279 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,288 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0011 state at FAILED
2016-05-17 23:24:27,288 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:27,288 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:27,288 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:27,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:27,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-17 23:24:27,289 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:27,290 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-17 23:24:27,290 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.060
2016-05-17 23:24:27,290 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-17 23:24:27,299 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,300 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-17 23:24:27,327 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 23:24:27,327 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:27,328 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-17 23:24:27,337 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:27,337 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-17 23:24:27,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:27,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:27,339 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:27,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-17 23:24:27,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0012
2016-05-17 23:24:27,366 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:27,371 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:27,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:27,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:27,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F01F86297A5E4656A04981C68DF1E838, ordinal: 0
2016-05-17 23:24:27,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-17 23:24:27,384 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F01F86297A5E4656A04981C68DF1E838, mem on start (mb), free: 228, total: 281, max: 672
2016-05-17 23:24:27,385 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,394 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,401 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,407 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F01F86297A5E4656A04981C68DF1E838, mem on close (mb), free: 228, total: 281, max: 672
2016-05-17 23:24:27,407 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0012
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:27,409 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0012 state at FAILED
2016-05-17 23:24:27,417 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:27,417 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:27,418 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:27,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:27,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-17 23:24:27,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:27,419 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-17 23:24:27,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.081
2016-05-17 23:24:27,419 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-17 23:24:27,429 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,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-17 23:24:27,444 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2016-05-17 23:24:27,445 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:27,446 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-17 23:24:27,457 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:27,458 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-17 23:24:27,488 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 23:24:27,489 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:27,489 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-17 23:24:27,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:27,500 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,500 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-17 23:24:27,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:27,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:27,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:27,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-17 23:24:27,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0013
2016-05-17 23:24:27,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:27,531 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:27,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:27,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:27,542 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD59A71E8BBF4EE1BEDC9289348D586A, ordinal: 0
2016-05-17 23:24:27,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:27,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-17 23:24:27,543 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD59A71E8BBF4EE1BEDC9289348D586A, mem on start (mb), free: 217, total: 281, max: 672
2016-05-17 23:24:27,545 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD59A71E8BBF4EE1BEDC9289348D586A, mem on close (mb), free: 217, total: 281, max: 672
2016-05-17 23:24:30,542 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-17 23:24:30,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.042
2016-05-17 23:24:30,561 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-17 23:24:30,570 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:30,571 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-17 23:24:30,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-17 23:24:30,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:30,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-17 23:24:30,600 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:30,601 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-17 23:24:30,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 23:24:30,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:30,638 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-17 23:24:30,651 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:30,652 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:30,652 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-17 23:24:30,652 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:30,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:30,653 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:30,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-17 23:24:30,711 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0014
2016-05-17 23:24:30,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:30,721 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:30,725 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:30,725 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:30,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E993195C44234A9E8EBDAB67A9C4B535, ordinal: 0
2016-05-17 23:24:30,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:30,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-17 23:24:30,739 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E993195C44234A9E8EBDAB67A9C4B535, mem on start (mb), free: 202, total: 281, max: 672
2016-05-17 23:24:30,742 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E993195C44234A9E8EBDAB67A9C4B535, mem on close (mb), free: 202, total: 281, max: 672
2016-05-17 23:24:33,730 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-17 23:24:33,731 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.079
2016-05-17 23:24:33,744 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-17 23:24:33,751 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:33,751 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-17 23:24:33,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 23:24:33,779 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:33,779 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-17 23:24:33,788 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:33,788 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:33,789 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-17 23:24:33,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:33,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:33,789 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:33,790 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-17 23:24:33,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0015
2016-05-17 23:24:33,812 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:33,815 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:33,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:33,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:33,825 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED18C1887BC84C5797CD6E5B1469D6F4, ordinal: 0
2016-05-17 23:24:33,826 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:33,826 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-17 23:24:33,826 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED18C1887BC84C5797CD6E5B1469D6F4, mem on start (mb), free: 190, total: 281, max: 672
2016-05-17 23:24:33,829 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED18C1887BC84C5797CD6E5B1469D6F4, mem on close (mb), free: 190, total: 281, max: 672
2016-05-17 23:24:36,825 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-17 23:24:36,826 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.037
2016-05-17 23:24:36,838 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-17 23:24:36,844 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:36,844 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-17 23:24:36,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 23:24:36,873 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:36,874 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-17 23:24:36,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:36,889 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:36,889 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-17 23:24:36,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:36,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:36,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:36,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-17 23:24:36,918 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0016
2016-05-17 23:24:36,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:36,923 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:36,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:36,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:36,935 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E5F876B55BDF4CA1905505F1A1B53F7F, ordinal: 0
2016-05-17 23:24:36,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:36,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-17 23:24:36,936 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5F876B55BDF4CA1905505F1A1B53F7F, mem on start (mb), free: 178, total: 281, max: 672
2016-05-17 23:24:36,947 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5F876B55BDF4CA1905505F1A1B53F7F, mem on close (mb), free: 178, total: 281, max: 672
2016-05-17 23:24:39,933 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-17 23:24:39,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.043
2016-05-17 23:24:39,946 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-17 23:24:39,952 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:39,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-17 23:24:39,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-17 23:24:39,977 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:39,978 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-17 23:24:39,986 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:39,986 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:39,986 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-17 23:24:39,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:39,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:39,987 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:39,988 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-17 23:24:40,011 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0017
2016-05-17 23:24:40,011 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:40,015 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:40,019 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:40,019 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:40,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACF16C888D514F54A3FA0FFFDC59EA7B, ordinal: 0
2016-05-17 23:24:40,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:40,028 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-17 23:24:40,028 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACF16C888D514F54A3FA0FFFDC59EA7B, mem on start (mb), free: 168, total: 281, max: 672
2016-05-17 23:24:40,030 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACF16C888D514F54A3FA0FFFDC59EA7B, mem on close (mb), free: 168, total: 281, max: 672
2016-05-17 23:24:43,024 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-17 23:24:43,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.038
2016-05-17 23:24:43,039 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-17 23:24:43,045 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:43,046 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-17 23:24:43,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-17 23:24:43,071 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:43,072 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-17 23:24:43,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:43,084 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:43,085 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-17 23:24:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:43,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-17 23:24:43,114 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0018
2016-05-17 23:24:43,115 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:43,118 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:43,121 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:43,121 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:43,129 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF76E234F4B24527B7A7AA7AC67FD01D, ordinal: 0
2016-05-17 23:24:43,130 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:43,130 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-17 23:24:43,130 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF76E234F4B24527B7A7AA7AC67FD01D, mem on start (mb), free: 156, total: 281, max: 672
2016-05-17 23:24:43,133 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF76E234F4B24527B7A7AA7AC67FD01D, mem on close (mb), free: 156, total: 281, max: 672
2016-05-17 23:24:46,129 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-17 23:24:46,130 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.044
2016-05-17 23:24:46,144 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-17 23:24:46,172 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:46,172 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-17 23:24:46,184 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-17 23:24:46,184 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:46,184 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-17 23:24:46,193 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:46,193 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-17 23:24:46,213 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-17 23:24:46,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:46,214 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-17 23:24:46,222 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:46,222 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:46,222 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-17 23:24:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:46,223 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:46,224 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-17 23:24:46,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0019
2016-05-17 23:24:46,248 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:46,252 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:46,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:46,254 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:46,261 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD63DCDA5E8E43B9A70027A9D1ACA7C3, ordinal: 0
2016-05-17 23:24:46,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:46,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-17 23:24:46,263 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD63DCDA5E8E43B9A70027A9D1ACA7C3, mem on start (mb), free: 261, total: 281, max: 672
2016-05-17 23:24:46,265 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD63DCDA5E8E43B9A70027A9D1ACA7C3, mem on close (mb), free: 261, total: 281, max: 672
2016-05-17 23:24:49,253 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-17 23:24:49,254 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.031
2016-05-17 23:24:49,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-17 23:24:49,273 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:49,273 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-17 23:24:49,294 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 23:24:49,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:49,296 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-17 23:24:49,311 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:49,312 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:49,312 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-17 23:24:49,312 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:49,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:49,313 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:49,314 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-17 23:24:49,345 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0020
2016-05-17 23:24:49,346 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:49,350 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:49,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:49,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:49,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EEE43531F83348F68DA320FAD78411EB, ordinal: 0
2016-05-17 23:24:49,366 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:49,366 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-17 23:24:49,366 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEE43531F83348F68DA320FAD78411EB, mem on start (mb), free: 251, total: 281, max: 672
2016-05-17 23:24:49,369 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEE43531F83348F68DA320FAD78411EB, mem on close (mb), free: 251, total: 281, max: 672
2016-05-17 23:24:52,359 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-17 23:24:52,360 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.048
2016-05-17 23:24:52,372 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-17 23:24:52,378 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:52,378 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-17 23:24:52,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-17 23:24:52,397 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:52,397 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-17 23:24:52,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:52,408 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,409 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-17 23:24:52,409 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:52,410 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:52,410 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:52,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-17 23:24:52,439 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0021
2016-05-17 23:24:52,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:52,444 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:52,447 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:52,447 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:52,457 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9784AF03079475AB98F36997E98B168, ordinal: 0
2016-05-17 23:24:52,459 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,459 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-17 23:24:52,460 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9784AF03079475AB98F36997E98B168, mem on start (mb), free: 240, total: 281, max: 672
2016-05-17 23:24:52,461 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,465 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,465 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,466 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9784AF03079475AB98F36997E98B168, mem on close (mb), free: 240, total: 281, max: 672
2016-05-17 23:24:52,466 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0021
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,475 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0021 state at FAILED
2016-05-17 23:24:52,476 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:52,476 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:52,476 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:52,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:52,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-17 23:24:52,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:52,477 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-17 23:24:52,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.069
2016-05-17 23:24:52,478 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-17 23:24:52,485 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:52,485 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-17 23:24:52,496 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-17 23:24:52,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:52,497 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-17 23:24:52,504 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:52,504 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-17 23:24:52,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-17 23:24:52,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:52,533 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-17 23:24:52,543 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:52,543 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,544 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-17 23:24:52,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:52,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:52,544 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:52,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-17 23:24:52,564 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0022
2016-05-17 23:24:52,564 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:52,567 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:52,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:52,570 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:52,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0576549B24F4AD88B2ED55F71257385, ordinal: 0
2016-05-17 23:24:52,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,580 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-17 23:24:52,580 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0576549B24F4AD88B2ED55F71257385, mem on start (mb), free: 230, total: 281, max: 672
2016-05-17 23:24:52,580 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,581 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,582 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,583 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0576549B24F4AD88B2ED55F71257385, mem on close (mb), free: 230, total: 281, max: 672
2016-05-17 23:24:52,584 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0022
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,586 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0022 state at FAILED
2016-05-17 23:24:52,586 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:52,586 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:52,586 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:52,586 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:52,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-17 23:24:52,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:52,587 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-17 23:24:52,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.044
2016-05-17 23:24:52,588 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-17 23:24:52,595 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:52,595 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-17 23:24:52,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-17 23:24:52,614 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:52,614 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-17 23:24:52,621 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:52,622 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,622 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-17 23:24:52,622 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:52,623 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:52,623 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:52,624 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-17 23:24:52,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0023
2016-05-17 23:24:52,650 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:52,653 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:52,656 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:52,656 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:52,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC70DCC7FD1E4FF1A5FE3B0303F08A82, ordinal: 0
2016-05-17 23:24:52,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-17 23:24:52,663 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC70DCC7FD1E4FF1A5FE3B0303F08A82, mem on start (mb), free: 221, total: 281, max: 672
2016-05-17 23:24:52,665 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,666 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,666 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,667 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC70DCC7FD1E4FF1A5FE3B0303F08A82, mem on close (mb), free: 221, total: 281, max: 672
2016-05-17 23:24:52,668 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0023
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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 13 more
2016-05-17 23:24:52,671 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local_0023 state at FAILED
2016-05-17 23:24:52,671 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-17 23:24:52,671 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-17 23:24:52,671 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-17 23:24:52,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-17 23:24:52,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-17 23:24:52,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-17 23:24:52,673 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-17 23:24:52,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:00.051
2016-05-17 23:24:52,674 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-17 23:24:52,682 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:52,682 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-17 23:24:52,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-17 23:24:52,706 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:52,706 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-17 23:24:52,714 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:52,715 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,715 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-17 23:24:52,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:52,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:52,716 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:52,717 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-17 23:24:52,737 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0024
2016-05-17 23:24:52,739 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:52,741 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:52,744 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:52,744 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:52,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA871BF7F9214A81B11FEBB5B934C50E, ordinal: 0
2016-05-17 23:24:52,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:52,754 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-17 23:24:52,754 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA871BF7F9214A81B11FEBB5B934C50E, mem on start (mb), free: 213, total: 281, max: 672
2016-05-17 23:24:52,757 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA871BF7F9214A81B11FEBB5B934C50E, mem on close (mb), free: 213, total: 281, max: 672
2016-05-17 23:24:55,752 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-17 23:24:55,753 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.038
2016-05-17 23:24:55,764 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-17 23:24:55,769 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:55,770 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-17 23:24:55,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-17 23:24:55,780 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:55,781 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-17 23:24:55,786 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:55,786 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-17 23:24:55,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 23:24:55,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:55,808 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-17 23:24:55,815 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:55,815 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:55,815 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-17 23:24:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:55,816 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-17 23:24:55,839 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0025
2016-05-17 23:24:55,840 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:55,843 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:55,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:55,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:55,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D595C5E9C3E24D0C88895A9F8164993D, ordinal: 0
2016-05-17 23:24:55,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:55,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-17 23:24:55,852 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D595C5E9C3E24D0C88895A9F8164993D, mem on start (mb), free: 200, total: 281, max: 672
2016-05-17 23:24:55,854 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D595C5E9C3E24D0C88895A9F8164993D, mem on close (mb), free: 200, total: 281, max: 672
2016-05-17 23:24:58,853 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-17 23:24:58,854 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.038
2016-05-17 23:24:58,867 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-17 23:24:58,872 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:58,872 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-17 23:24:58,882 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-17 23:24:58,883 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:24:58,883 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-17 23:24:58,889 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:24:58,889 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-17 23:24:58,908 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-17 23:24:58,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:24:58,909 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-17 23:24:58,916 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:24:58,917 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:58,917 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-17 23:24:58,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:24:58,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:24:58,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:24:58,917 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-17 23:24:58,939 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0026
2016-05-17 23:24:58,940 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:24:58,942 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:24:58,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:24:58,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:24:58,950 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E23D92288A1D4B17BCFDA7390DDAAE6D, ordinal: 0
2016-05-17 23:24:58,951 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:24:58,951 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-17 23:24:58,951 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E23D92288A1D4B17BCFDA7390DDAAE6D, mem on start (mb), free: 183, total: 281, max: 672
2016-05-17 23:24:58,954 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E23D92288A1D4B17BCFDA7390DDAAE6D, mem on close (mb), free: 183, total: 281, max: 672
2016-05-17 23:25:01,946 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-17 23:25:01,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.030
2016-05-17 23:25:01,958 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-17 23:25:01,963 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:01,963 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-17 23:25:01,983 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-17 23:25:01,984 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:25:01,985 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-17 23:25:01,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:25:01,995 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:01,995 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-17 23:25:01,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:25:01,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:25:01,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:25:01,996 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-17 23:25:02,024 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0027
2016-05-17 23:25:02,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:25:02,029 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:25:02,033 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:25:02,033 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:25:02,042 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF9BAD41E40A4B80A4AC6BB8EB162B5D, ordinal: 0
2016-05-17 23:25:02,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:02,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-17 23:25:02,044 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF9BAD41E40A4B80A4AC6BB8EB162B5D, mem on start (mb), free: 172, total: 281, max: 672
2016-05-17 23:25:02,048 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF9BAD41E40A4B80A4AC6BB8EB162B5D, mem on close (mb), free: 172, total: 281, max: 672
2016-05-17 23:25:05,039 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-17 23:25:05,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.045
2016-05-17 23:25:05,051 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-17 23:25:05,058 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:05,058 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-17 23:25:05,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-17 23:25:05,079 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:25:05,080 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-17 23:25:05,091 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:25:05,091 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:05,092 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-17 23:25:05,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:25:05,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:25:05,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:25:05,092 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-17 23:25:05,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0028
2016-05-17 23:25:05,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:25:05,114 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:25:05,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:25:05,117 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:25:05,122 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8A05BB49AAE45D5BFC0537AF9CFA7FE, ordinal: 0
2016-05-17 23:25:05,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:05,123 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-17 23:25:05,123 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8A05BB49AAE45D5BFC0537AF9CFA7FE, mem on start (mb), free: 162, total: 281, max: 672
2016-05-17 23:25:05,125 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8A05BB49AAE45D5BFC0537AF9CFA7FE, mem on close (mb), free: 162, total: 281, max: 672
2016-05-17 23:25:08,125 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-17 23:25:08,126 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.034
2016-05-17 23:25:08,137 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-17 23:25:08,143 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:08,143 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-17 23:25:08,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-17 23:25:08,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:25:08,163 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-17 23:25:08,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:25:08,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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:08,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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-17 23:25:08,182 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:25:08,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:25:08,185 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:25:08,190 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-17 23:25:08,211 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0029
2016-05-17 23:25:08,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:25:08,214 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:25:08,217 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:25:08,217 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:25:08,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F4A6D78927F0481E9994044D66ADD161, ordinal: 0
2016-05-17 23:25:08,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:08,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-17 23:25:08,225 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4A6D78927F0481E9994044D66ADD161, mem on start (mb), free: 263, total: 276, max: 672
2016-05-17 23:25:08,227 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4A6D78927F0481E9994044D66ADD161, mem on close (mb), free: 263, total: 276, max: 672
2016-05-17 23:25:11,216 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-17 23:25:11,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.038
2016-05-17 23:25:11,229 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-17 23:25:11,235 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:11,235 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-17 23:25:11,255 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-17 23:25:11,256 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:25:11,256 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-17 23:25:11,262 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:25:11,262 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:11,262 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-17 23:25:11,262 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:25:11,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:25:11,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:25:11,265 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-17 23:25:11,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0030
2016-05-17 23:25:11,286 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:25:11,290 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:25:11,292 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:25:11,293 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:25:11,299 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A353EF1DD6684C1EB11648847EBF6FB2, ordinal: 0
2016-05-17 23:25:11,300 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:11,300 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-17 23:25:11,301 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A353EF1DD6684C1EB11648847EBF6FB2, mem on start (mb), free: 252, total: 276, max: 672
2016-05-17 23:25:11,303 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A353EF1DD6684C1EB11648847EBF6FB2, mem on close (mb), free: 252, total: 276, max: 672
2016-05-17 23:25:14,300 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-17 23:25:14,300 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.038
2016-05-17 23:25:14,312 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-17 23:25:14,318 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:14,318 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-17 23:25:14,335 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-17 23:25:14,336 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 23:25:14,336 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-17 23:25:14,342 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-17 23:25:14,343 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-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:14,344 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-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-17 23:25:14,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] parallel execution of steps is enabled: false
2016-05-17 23:25:14,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executing total steps: 1
2016-05-17 23:25:14,345 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] allocating management threads: 1
2016-05-17 23:25:14,346 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-17 23:25:14,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local_0031
2016-05-17 23:25:14,364 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-17 23:25:14,366 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-05-17 23:25:14,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 23:25:14,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 23:25:14,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AD65FB9BAFD54BF0B4A1289783286C3D, ordinal: 0
2016-05-17 23:25:14,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-05-17 23:25:14,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-17 23:25:14,375 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD65FB9BAFD54BF0B4A1289783286C3D, mem on start (mb), free: 241, total: 276, max: 672
2016-05-17 23:25:14,377 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD65FB9BAFD54BF0B4A1289783286C3D, mem on close (mb), free: 241, total: 276, max: 672
2016-05-17 23:25:17,378 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-17 23:25:17,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] completed in: 00:03.036
2016-05-17 23:25:17,391 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-17 23:25:17,396 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 23:25:17,396 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-17 23:25:17,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-17 23:25:17,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 23:25:17,406 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'