2016-01-14 22:24:28,952 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 22:24:28,967 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop
2016-01-14 22:24:29,392 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 22:24:29,643 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 22:24:29,721 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:29,723 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:29,842 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: CD979323F7314761AF2C2180C53EC112
2016-01-14 22:24:29,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.095
2016-01-14 22:24:29,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:29,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:30,138 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 22:24:30,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:30,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:30,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 22:24:30,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:30,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:30,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:30,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-14 22:24:30,188 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 22:24:30,250 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 22:24:30,514 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0001
2016-01-14 22:24:30,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:30,596 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:30,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:30,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:30,628 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A99350084196434CB9D6EBA03124C6FA, ordinal: 0
2016-01-14 22:24:30,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:30,670 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 22:24:30,671 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A99350084196434CB9D6EBA03124C6FA, mem on start (mb), free: 238, total: 281, max: 672
2016-01-14 22:24:30,684 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A99350084196434CB9D6EBA03124C6FA, mem on close (mb), free: 237, total: 281, max: 672
2016-01-14 22:24:30,700 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-14 22:24:30,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.559
2016-01-14 22:24:30,739 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-14 22:24:30,756 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:30,757 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:30,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-01-14 22:24:30,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:30,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:30,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:30,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 22:24:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:30,842 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-14 22:24:30,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0002
2016-01-14 22:24:30,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:30,928 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:30,933 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:30,933 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:30,961 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F4943C57BFE0464FA6D7D57381F29CB1, ordinal: 0
2016-01-14 22:24:30,963 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:30,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 22:24:30,964 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4943C57BFE0464FA6D7D57381F29CB1, mem on start (mb), free: 221, total: 281, max: 672
2016-01-14 22:24:30,967 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4943C57BFE0464FA6D7D57381F29CB1, mem on close (mb), free: 221, total: 281, max: 672
2016-01-14 22:24:30,989 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-14 22:24:30,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.150
2016-01-14 22:24:31,048 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-14 22:24:31,071 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:31,072 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:31,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 22:24:31,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:31,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:31,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:31,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 22:24:31,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:31,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:31,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:31,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-14 22:24:31,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0003
2016-01-14 22:24:31,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:31,243 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:31,250 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:31,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:31,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FAEEAEF4224F4E7D9DFFECE06C78390F, ordinal: 0
2016-01-14 22:24:31,267 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,268 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 22:24:31,268 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAEEAEF4224F4E7D9DFFECE06C78390F, mem on start (mb), free: 209, total: 281, max: 672
2016-01-14 22:24:31,272 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAEEAEF4224F4E7D9DFFECE06C78390F, mem on close (mb), free: 209, total: 281, max: 672
2016-01-14 22:24:31,288 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-14 22:24:31,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.132
2016-01-14 22:24:31,326 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-14 22:24:31,341 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:31,341 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:31,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-01-14 22:24:31,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:31,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:31,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:31,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 22:24:31,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:31,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:31,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:31,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-14 22:24:31,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0004
2016-01-14 22:24:31,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:31,522 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:31,527 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:31,527 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:31,537 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D3375EEF9E934E96981D5253C80B6594, ordinal: 0
2016-01-14 22:24:31,538 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 22:24:31,539 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3375EEF9E934E96981D5253C80B6594, mem on start (mb), free: 194, total: 281, max: 672
2016-01-14 22:24:31,542 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3375EEF9E934E96981D5253C80B6594, mem on close (mb), free: 194, total: 281, max: 672
2016-01-14 22:24:31,558 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-14 22:24:31,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.128
2016-01-14 22:24:31,594 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-14 22:24:31,606 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:31,607 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:31,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 22:24:31,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:31,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:31,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:31,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 22:24:31,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:31,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:31,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:31,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-14 22:24:31,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0005
2016-01-14 22:24:31,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:31,733 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:31,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:31,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:31,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E990BA87852548CE92A7DFC4E4489CC7, ordinal: 0
2016-01-14 22:24:31,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 22:24:31,751 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E990BA87852548CE92A7DFC4E4489CC7, mem on start (mb), free: 182, total: 281, max: 672
2016-01-14 22:24:31,754 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E990BA87852548CE92A7DFC4E4489CC7, mem on close (mb), free: 182, total: 281, max: 672
2016-01-14 22:24:31,769 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-14 22:24:31,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.105
2016-01-14 22:24:31,793 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-14 22:24:31,802 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:31,802 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:31,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-01-14 22:24:31,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:31,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:31,858 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:31,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 22:24:31,859 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:31,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:31,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:31,861 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-14 22:24:31,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0006
2016-01-14 22:24:31,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:31,916 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:31,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:31,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:31,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5CC76B515974E92B0DA85DB690FD312, ordinal: 0
2016-01-14 22:24:31,932 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:31,932 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 22:24:31,932 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5CC76B515974E92B0DA85DB690FD312, mem on start (mb), free: 170, total: 281, max: 672
2016-01-14 22:24:31,935 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5CC76B515974E92B0DA85DB690FD312, mem on close (mb), free: 170, total: 281, max: 672
2016-01-14 22:24:31,942 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-14 22:24:31,943 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.084
2016-01-14 22:24:31,966 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-14 22:24:31,975 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:31,976 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.021
2016-01-14 22:24:32,001 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:32,002 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-14 22:24:32,011 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,012 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 22:24:32,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 22:24:32,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-14 22:24:32,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0007
2016-01-14 22:24:32,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,123 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,129 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC1524E2676948F3B40FECE46BD55603, ordinal: 0
2016-01-14 22:24:32,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,138 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 22:24:32,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC1524E2676948F3B40FECE46BD55603, mem on start (mb), free: 264, total: 281, max: 672
2016-01-14 22:24:32,142 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC1524E2676948F3B40FECE46BD55603, mem on close (mb), free: 264, total: 281, max: 672
2016-01-14 22:24:32,152 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-14 22:24:32,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.072
2016-01-14 22:24:32,177 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-14 22:24:32,185 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,186 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 22:24:32,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 22:24:32,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-14 22:24:32,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0008
2016-01-14 22:24:32,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,275 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,281 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,282 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,293 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BAEF6128234C4D709D7E82011549F92C, ordinal: 0
2016-01-14 22:24:32,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 22:24:32,296 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAEF6128234C4D709D7E82011549F92C, mem on start (mb), free: 251, total: 281, max: 672
2016-01-14 22:24:32,298 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAEF6128234C4D709D7E82011549F92C, mem on close (mb), free: 251, total: 281, max: 672
2016-01-14 22:24:32,312 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-14 22:24:32,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.082
2016-01-14 22:24:32,334 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-14 22:24:32,343 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,344 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,382 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 22:24:32,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 22:24:32,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 22:24:32,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0009
2016-01-14 22:24:32,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,431 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,441 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FC7882D43C254B6BBE2695BE5CF000FF, ordinal: 0
2016-01-14 22:24:32,442 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,442 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 22:24:32,442 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC7882D43C254B6BBE2695BE5CF000FF, mem on start (mb), free: 238, total: 281, max: 672
2016-01-14 22:24:32,444 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC7882D43C254B6BBE2695BE5CF000FF, mem on close (mb), free: 238, total: 281, max: 672
2016-01-14 22:24:32,459 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-14 22:24:32,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.061
2016-01-14 22:24:32,474 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 22:24:32,482 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,483 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 22:24:32,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 22:24:32,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 22:24:32,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0010
2016-01-14 22:24:32,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,562 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4B3B9B15A984B5E912D12194BB0FD27, ordinal: 0
2016-01-14 22:24:32,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 22:24:32,577 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4B3B9B15A984B5E912D12194BB0FD27, mem on start (mb), free: 225, total: 281, max: 672
2016-01-14 22:24:32,578 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,580 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,581 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,582 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4B3B9B15A984B5E912D12194BB0FD27, mem on close (mb), free: 225, total: 281, max: 672
2016-01-14 22:24:32,584 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0010
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,585 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0010 state at FAILED
2016-01-14 22:24:32,587 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:32,589 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:32,590 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:32,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:32,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 22:24:32,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:32,591 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-14 22:24:32,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.063
2016-01-14 22:24:32,592 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-14 22:24:32,601 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,601 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-01-14 22:24:32,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:32,620 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-14 22:24:32,627 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,628 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 22:24:32,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 22:24:32,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 22:24:32,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0011
2016-01-14 22:24:32,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,712 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,715 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,715 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,722 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5DCFF83A8A2445D9346028A33E7D3CE, ordinal: 0
2016-01-14 22:24:32,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,725 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 22:24:32,725 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5DCFF83A8A2445D9346028A33E7D3CE, mem on start (mb), free: 211, total: 281, max: 672
2016-01-14 22:24:32,726 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,727 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,727 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,728 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5DCFF83A8A2445D9346028A33E7D3CE, mem on close (mb), free: 211, total: 281, max: 672
2016-01-14 22:24:32,729 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0011
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,730 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0011 state at FAILED
2016-01-14 22:24:32,731 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:32,731 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:32,731 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:32,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:32,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 22:24:32,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:32,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] shutting down job executor
2016-01-14 22:24:32,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] shutdown complete
2016-01-14 22:24:32,735 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-14 22:24:32,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.055
2016-01-14 22:24:32,737 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-14 22:24:32,746 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,747 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 22:24:32,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 22:24:32,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 22:24:32,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0012
2016-01-14 22:24:32,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,838 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E004B6543DB04A2FB43F049EF55CA7A2, ordinal: 0
2016-01-14 22:24:32,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 22:24:32,855 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E004B6543DB04A2FB43F049EF55CA7A2, mem on start (mb), free: 201, total: 281, max: 672
2016-01-14 22:24:32,856 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,857 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,857 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,858 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E004B6543DB04A2FB43F049EF55CA7A2, mem on close (mb), free: 201, total: 281, max: 672
2016-01-14 22:24:32,859 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0012
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:32,864 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0012 state at FAILED
2016-01-14 22:24:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:32,865 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:32,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:32,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 22:24:32,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:32,867 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-14 22:24:32,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.081
2016-01-14 22:24:32,868 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-14 22:24:32,878 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,878 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-01-14 22:24:32,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:32,897 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-14 22:24:32,915 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:32,915 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:32,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 22:24:32,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:32,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:32,956 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:32,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 22:24:32,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:32,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:32,958 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:32,958 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-14 22:24:32,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0013
2016-01-14 22:24:32,984 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:32,987 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:32,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:32,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:32,998 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF3C59CD3FEB40AAA8DAD3729E3FDDC8, ordinal: 0
2016-01-14 22:24:32,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:32,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 22:24:33,000 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF3C59CD3FEB40AAA8DAD3729E3FDDC8, mem on start (mb), free: 187, total: 281, max: 672
2016-01-14 22:24:33,002 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF3C59CD3FEB40AAA8DAD3729E3FDDC8, mem on close (mb), free: 187, total: 281, max: 672
2016-01-14 22:24:33,017 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-14 22:24:33,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.061
2016-01-14 22:24:33,032 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-14 22:24:33,039 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,040 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-01-14 22:24:33,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:33,055 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-14 22:24:33,065 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,066 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 22:24:33,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,099 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 22:24:33,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-14 22:24:33,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0014
2016-01-14 22:24:33,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,144 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,147 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,147 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABBD16CAB6C6419AA4FC8B109BF414A6, ordinal: 0
2016-01-14 22:24:33,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,155 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 22:24:33,155 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABBD16CAB6C6419AA4FC8B109BF414A6, mem on start (mb), free: 172, total: 281, max: 672
2016-01-14 22:24:33,157 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABBD16CAB6C6419AA4FC8B109BF414A6, mem on close (mb), free: 172, total: 281, max: 672
2016-01-14 22:24:33,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-14 22:24:33,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.063
2016-01-14 22:24:33,185 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-14 22:24:33,192 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,192 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 22:24:33,215 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,215 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 22:24:33,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-14 22:24:33,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0015
2016-01-14 22:24:33,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,251 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,261 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F7303EF371B84194AC29A71135EE85BF, ordinal: 0
2016-01-14 22:24:33,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 22:24:33,262 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7303EF371B84194AC29A71135EE85BF, mem on start (mb), free: 159, total: 281, max: 672
2016-01-14 22:24:33,265 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7303EF371B84194AC29A71135EE85BF, mem on close (mb), free: 159, total: 281, max: 672
2016-01-14 22:24:33,279 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-14 22:24:33,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.056
2016-01-14 22:24:33,293 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-14 22:24:33,300 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,301 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 22:24:33,345 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 22:24:33,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-14 22:24:33,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0016
2016-01-14 22:24:33,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,389 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,392 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,393 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,399 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8C371DE7B8943038B49F9263D06C65E, ordinal: 0
2016-01-14 22:24:33,400 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,400 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 22:24:33,400 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8C371DE7B8943038B49F9263D06C65E, mem on start (mb), free: 378, total: 397, max: 672
2016-01-14 22:24:33,403 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8C371DE7B8943038B49F9263D06C65E, mem on close (mb), free: 378, total: 397, max: 672
2016-01-14 22:24:33,418 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-14 22:24:33,418 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.062
2016-01-14 22:24:33,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-14 22:24:33,438 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,439 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 22:24:33,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 22:24:33,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-14 22:24:33,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0017
2016-01-14 22:24:33,498 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,503 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,513 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B8A33049F13749FEB34C6D25DA1D03C0, ordinal: 0
2016-01-14 22:24:33,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 22:24:33,515 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8A33049F13749FEB34C6D25DA1D03C0, mem on start (mb), free: 366, total: 397, max: 672
2016-01-14 22:24:33,518 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B8A33049F13749FEB34C6D25DA1D03C0, mem on close (mb), free: 366, total: 397, max: 672
2016-01-14 22:24:33,533 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-14 22:24:33,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.061
2016-01-14 22:24:33,547 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-14 22:24:33,553 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,554 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 22:24:33,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 22:24:33,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-14 22:24:33,610 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0018
2016-01-14 22:24:33,612 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,616 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,626 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E0EF977A0D014ED3BEFF16F5CB07B252, ordinal: 0
2016-01-14 22:24:33,627 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,627 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 22:24:33,627 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EF977A0D014ED3BEFF16F5CB07B252, mem on start (mb), free: 351, total: 397, max: 672
2016-01-14 22:24:33,630 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EF977A0D014ED3BEFF16F5CB07B252, mem on close (mb), free: 351, total: 397, max: 672
2016-01-14 22:24:33,644 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-14 22:24:33,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.058
2016-01-14 22:24:33,658 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-14 22:24:33,663 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,664 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-14 22:24:33,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:33,674 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-14 22:24:33,680 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,680 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 22:24:33,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 22:24:33,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-14 22:24:33,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0019
2016-01-14 22:24:33,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,735 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,744 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B99B725BFC78492EBA45683A77400BD1, ordinal: 0
2016-01-14 22:24:33,745 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,745 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 22:24:33,745 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B99B725BFC78492EBA45683A77400BD1, mem on start (mb), free: 333, total: 397, max: 672
2016-01-14 22:24:33,747 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B99B725BFC78492EBA45683A77400BD1, mem on close (mb), free: 333, total: 397, max: 672
2016-01-14 22:24:33,753 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-14 22:24:33,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.045
2016-01-14 22:24:33,767 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-14 22:24:33,773 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,773 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 22:24:33,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 22:24:33,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-14 22:24:33,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0020
2016-01-14 22:24:33,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,841 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DCE983A4822A40419665B84F84D904B1, ordinal: 0
2016-01-14 22:24:33,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 22:24:33,851 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCE983A4822A40419665B84F84D904B1, mem on start (mb), free: 321, total: 397, max: 672
2016-01-14 22:24:33,854 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCE983A4822A40419665B84F84D904B1, mem on close (mb), free: 321, total: 397, max: 672
2016-01-14 22:24:33,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-14 22:24:33,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.049
2016-01-14 22:24:33,874 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-14 22:24:33,879 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,880 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 22:24:33,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:33,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 22:24:33,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:33,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:33,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:33,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 22:24:33,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0021
2016-01-14 22:24:33,932 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:33,937 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:33,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:33,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:33,946 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B84D79C016D6426EB7156A09D36355C4, ordinal: 0
2016-01-14 22:24:33,947 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:33,947 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 22:24:33,947 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B84D79C016D6426EB7156A09D36355C4, mem on start (mb), free: 307, total: 397, max: 672
2016-01-14 22:24:33,948 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:33,948 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:33,948 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:33,948 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B84D79C016D6426EB7156A09D36355C4, mem on close (mb), free: 307, total: 397, max: 672
2016-01-14 22:24:33,949 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0021
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:33,951 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0021 state at FAILED
2016-01-14 22:24:33,951 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:33,951 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:33,951 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:33,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:33,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 22:24:33,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:33,962 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-14 22:24:33,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.054
2016-01-14 22:24:33,963 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-14 22:24:33,971 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,971 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:33,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 22:24:33,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:33,981 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-14 22:24:33,990 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:33,990 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 22:24:34,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,020 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 22:24:34,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 22:24:34,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0022
2016-01-14 22:24:34,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,060 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,068 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1960034DBB240F5AEF83C91B03CCC78, ordinal: 0
2016-01-14 22:24:34,068 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,069 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 22:24:34,069 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1960034DBB240F5AEF83C91B03CCC78, mem on start (mb), free: 290, total: 397, max: 672
2016-01-14 22:24:34,070 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,073 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,076 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,081 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1960034DBB240F5AEF83C91B03CCC78, mem on close (mb), free: 290, total: 397, max: 672
2016-01-14 22:24:34,082 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0022
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,088 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0022 state at FAILED
2016-01-14 22:24:34,089 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:34,089 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:34,089 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:34,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:34,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 22:24:34,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:34,090 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-14 22:24:34,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.070
2016-01-14 22:24:34,090 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-14 22:24:34,096 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,096 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 22:24:34,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 22:24:34,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 22:24:34,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0023
2016-01-14 22:24:34,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,151 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,154 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,163 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C841D61334B44193A60F736D83E7C04C, ordinal: 0
2016-01-14 22:24:34,164 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,164 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 22:24:34,164 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C841D61334B44193A60F736D83E7C04C, mem on start (mb), free: 277, total: 397, max: 672
2016-01-14 22:24:34,165 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,166 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,174 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,180 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C841D61334B44193A60F736D83E7C04C, mem on close (mb), free: 277, total: 397, max: 672
2016-01-14 22:24:34,181 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0023
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2016-01-14 22:24:34,183 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0023 state at FAILED
2016-01-14 22:24:34,188 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 22:24:34,188 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 22:24:34,188 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 22:24:34,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 22:24:34,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 22:24:34,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 22:24:34,189 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-14 22:24:34,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.065
2016-01-14 22:24:34,190 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-14 22:24:34,199 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,199 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 22:24:34,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 22:24:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-14 22:24:34,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0024
2016-01-14 22:24:34,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,268 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,276 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF2367D76A814A4BBBC851FC35B6DB0A, ordinal: 0
2016-01-14 22:24:34,276 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,277 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 22:24:34,277 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF2367D76A814A4BBBC851FC35B6DB0A, mem on start (mb), free: 264, total: 397, max: 672
2016-01-14 22:24:34,279 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF2367D76A814A4BBBC851FC35B6DB0A, mem on close (mb), free: 264, total: 397, max: 672
2016-01-14 22:24:34,286 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-14 22:24:34,287 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.053
2016-01-14 22:24:34,306 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-14 22:24:34,314 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,315 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-01-14 22:24:34,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:34,326 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-14 22:24:34,335 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,336 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 22:24:34,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 22:24:34,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-14 22:24:34,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0025
2016-01-14 22:24:34,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,407 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AA7BF983E5F44450923E788E533F2251, ordinal: 0
2016-01-14 22:24:34,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 22:24:34,417 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA7BF983E5F44450923E788E533F2251, mem on start (mb), free: 246, total: 397, max: 672
2016-01-14 22:24:34,419 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA7BF983E5F44450923E788E533F2251, mem on close (mb), free: 246, total: 397, max: 672
2016-01-14 22:24:34,426 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-14 22:24:34,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.049
2016-01-14 22:24:34,443 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-14 22:24:34,450 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,451 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 22:24:34,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:34,462 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-14 22:24:34,471 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,472 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 22:24:34,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 22:24:34,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-14 22:24:34,547 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0026
2016-01-14 22:24:34,548 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,552 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,557 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,557 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,571 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E38BF7CED3724F66929948D77F75BBF8, ordinal: 0
2016-01-14 22:24:34,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 22:24:34,573 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E38BF7CED3724F66929948D77F75BBF8, mem on start (mb), free: 231, total: 397, max: 672
2016-01-14 22:24:34,577 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E38BF7CED3724F66929948D77F75BBF8, mem on close (mb), free: 231, total: 397, max: 672
2016-01-14 22:24:34,595 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-14 22:24:34,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.092
2016-01-14 22:24:34,612 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-14 22:24:34,620 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,620 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 22:24:34,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 22:24:34,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,664 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-14 22:24:34,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0027
2016-01-14 22:24:34,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,698 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D64E1CC26E49457EBCBC8174C3A3EA5F, ordinal: 0
2016-01-14 22:24:34,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,714 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 22:24:34,715 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D64E1CC26E49457EBCBC8174C3A3EA5F, mem on start (mb), free: 216, total: 397, max: 672
2016-01-14 22:24:34,718 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D64E1CC26E49457EBCBC8174C3A3EA5F, mem on close (mb), free: 216, total: 397, max: 672
2016-01-14 22:24:34,726 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-14 22:24:34,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.065
2016-01-14 22:24:34,749 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-14 22:24:34,759 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,759 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 22:24:34,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 22:24:34,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-14 22:24:34,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0028
2016-01-14 22:24:34,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,842 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,845 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,846 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BD0283FD8A3748F3A86215ABEB73A188, ordinal: 0
2016-01-14 22:24:34,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 22:24:34,852 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD0283FD8A3748F3A86215ABEB73A188, mem on start (mb), free: 202, total: 397, max: 672
2016-01-14 22:24:34,855 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD0283FD8A3748F3A86215ABEB73A188, mem on close (mb), free: 202, total: 397, max: 672
2016-01-14 22:24:34,868 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-14 22:24:34,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.075
2016-01-14 22:24:34,883 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-14 22:24:34,890 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:34,890 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:34,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 22:24:34,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:34,912 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:34,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:34,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 22:24:34,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:34,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:34,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:34,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-14 22:24:34,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0029
2016-01-14 22:24:34,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:34,954 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:34,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:34,958 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:34,965 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BCF92E07ABA34BD3955336AFEA5141E0, ordinal: 0
2016-01-14 22:24:34,966 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:34,966 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 22:24:34,967 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCF92E07ABA34BD3955336AFEA5141E0, mem on start (mb), free: 187, total: 397, max: 672
2016-01-14 22:24:34,969 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BCF92E07ABA34BD3955336AFEA5141E0, mem on close (mb), free: 187, total: 397, max: 672
2016-01-14 22:24:34,983 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-14 22:24:34,983 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.062
2016-01-14 22:24:34,999 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-14 22:24:35,006 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:35,006 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:35,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 22:24:35,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:35,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:35,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:35,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:35,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 22:24:35,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:35,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:35,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:35,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-14 22:24:35,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0030
2016-01-14 22:24:35,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:35,081 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:35,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:35,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:35,090 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B9E19025B16640AE99CC1FFDDA63F8B8, ordinal: 0
2016-01-14 22:24:35,091 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:35,091 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 22:24:35,091 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9E19025B16640AE99CC1FFDDA63F8B8, mem on start (mb), free: 175, total: 397, max: 672
2016-01-14 22:24:35,094 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9E19025B16640AE99CC1FFDDA63F8B8, mem on close (mb), free: 175, total: 397, max: 672
2016-01-14 22:24:35,107 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-14 22:24:35,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.072
2016-01-14 22:24:35,124 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-14 22:24:35,132 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:35,132 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:35,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 22:24:35,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 22:24:35,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 22:24:35,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 22:24:35,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:35,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 22:24:35,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 22:24:35,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 22:24:35,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 22:24:35,171 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 22:24:35,195 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0031
2016-01-14 22:24:35,195 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 22:24:35,198 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt
2016-01-14 22:24:35,201 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 22:24:35,201 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 22:24:35,206 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F19C5C636519469CAA6EDFD8C4C54D0A, ordinal: 0
2016-01-14 22:24:35,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2016-01-14 22:24:35,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 22:24:35,207 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F19C5C636519469CAA6EDFD8C4C54D0A, mem on start (mb), free: 161, total: 397, max: 672
2016-01-14 22:24:35,210 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F19C5C636519469CAA6EDFD8C4C54D0A, mem on close (mb), free: 161, total: 397, max: 672
2016-01-14 22:24:35,216 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-14 22:24:35,217 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.047
2016-01-14 22:24:35,234 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 22:24:35,242 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 22:24:35,243 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 22:24:35,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-01-14 22:24:35,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 22:24:35,277 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.1.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'