2016-01-14 23:51:27,448 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 23:51:27,464 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EveryEveryPipeAssemblyPlatformTest, with platform: hadoop
2016-01-14 23:51:27,872 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 23:51:28,079 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 23:51:28,159 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:28,161 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 23:51:28,250 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5AEAC0C75AFF47B785D04B82E56E5E3F
2016-01-14 23:51:28,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.092
2016-01-14 23:51:28,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:28,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:28,525 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 23:51:28,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:28,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:28,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 23:51:28,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:28,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:28,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:28,531 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-14 23:51:28,565 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 23:51:28,616 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 23:51:28,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local366830865_0001
2016-01-14 23:51:28,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:28,898 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:28,911 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:28,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:28,925 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A47C8D85CA5F4D19BEC5931F14633A4D, ordinal: 0
2016-01-14 23:51:28,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:28,968 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 23:51:28,969 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A47C8D85CA5F4D19BEC5931F14633A4D, mem on start (mb), free: 181, total: 223, max: 672
2016-01-14 23:51:28,979 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A47C8D85CA5F4D19BEC5931F14633A4D, mem on close (mb), free: 180, total: 223, max: 672
2016-01-14 23:51:29,001 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-14 23:51:29,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.473
2016-01-14 23:51:29,041 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-14 23:51:29,058 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:29,059 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 23:51:29,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-01-14 23:51:29,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:29,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:29,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:29,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 23:51:29,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:29,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:29,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:29,132 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-14 23:51:29,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1066701506_0002
2016-01-14 23:51:29,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:29,262 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:29,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:29,270 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:29,287 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D00327494A3449BA844070DD979F6D29, ordinal: 0
2016-01-14 23:51:29,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,289 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 23:51:29,289 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D00327494A3449BA844070DD979F6D29, mem on start (mb), free: 166, total: 223, max: 672
2016-01-14 23:51:29,292 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D00327494A3449BA844070DD979F6D29, mem on close (mb), free: 166, total: 223, max: 672
2016-01-14 23:51:29,308 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-14 23:51:29,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.177
2016-01-14 23:51:29,364 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-14 23:51:29,387 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:29,388 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 23:51:29,459 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 23:51:29,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:29,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:29,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:29,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 23:51:29,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:29,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:29,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:29,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-14 23:51:29,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2093277214_0003
2016-01-14 23:51:29,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:29,572 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:29,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:29,579 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:29,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AA968AFA0FE84AA9B1FC741822243C6A, ordinal: 0
2016-01-14 23:51:29,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 23:51:29,596 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA968AFA0FE84AA9B1FC741822243C6A, mem on start (mb), free: 208, total: 223, max: 672
2016-01-14 23:51:29,599 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AA968AFA0FE84AA9B1FC741822243C6A, mem on close (mb), free: 208, total: 223, max: 672
2016-01-14 23:51:29,619 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-14 23:51:29,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.124
2016-01-14 23:51:29,640 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-14 23:51:29,648 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:29,649 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 23:51:29,690 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 23:51:29,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:29,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:29,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:29,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 23:51:29,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:29,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:29,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:29,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-14 23:51:29,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1430181783_0004
2016-01-14 23:51:29,755 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:29,759 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:29,764 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:29,764 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:29,774 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D27B4CE5D68A4A238D0C7428DFC37425, ordinal: 0
2016-01-14 23:51:29,775 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,776 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 23:51:29,776 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D27B4CE5D68A4A238D0C7428DFC37425, mem on start (mb), free: 195, total: 223, max: 672
2016-01-14 23:51:29,779 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D27B4CE5D68A4A238D0C7428DFC37425, mem on close (mb), free: 195, total: 223, max: 672
2016-01-14 23:51:29,797 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-14 23:51:29,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.093
2016-01-14 23:51:29,818 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-14 23:51:29,826 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:29,827 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 23:51:29,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 23:51:29,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:29,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:29,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:29,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 23:51:29,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:29,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:29,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:29,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-14 23:51:29,920 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local8532961_0005
2016-01-14 23:51:29,920 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:29,924 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:29,928 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:29,929 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:29,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F013EF01159B4C058D43362A67D80534, ordinal: 0
2016-01-14 23:51:29,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:29,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 23:51:29,940 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F013EF01159B4C058D43362A67D80534, mem on start (mb), free: 183, total: 223, max: 672
2016-01-14 23:51:29,942 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F013EF01159B4C058D43362A67D80534, mem on close (mb), free: 183, total: 223, max: 672
2016-01-14 23:51:29,952 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-14 23:51:29,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.075
2016-01-14 23:51:29,970 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-14 23:51:29,978 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:29,978 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 23:51:30,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 23:51:30,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 23:51:30,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-14 23:51:30,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1679293561_0006
2016-01-14 23:51:30,066 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,070 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,082 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FFE77881828E43BAAC0870F0FCC79957, ordinal: 0
2016-01-14 23:51:30,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,084 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 23:51:30,084 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FFE77881828E43BAAC0870F0FCC79957, mem on start (mb), free: 170, total: 223, max: 672
2016-01-14 23:51:30,086 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FFE77881828E43BAAC0870F0FCC79957, mem on close (mb), free: 170, total: 223, max: 672
2016-01-14 23:51:30,098 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-14 23:51:30,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.072
2016-01-14 23:51:30,119 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-14 23:51:30,127 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,128 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 23:51:30,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-01-14 23:51:30,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:30,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-14 23:51:30,152 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,153 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 23:51:30,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 23:51:30,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 23:51:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-14 23:51:30,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local775660702_0007
2016-01-14 23:51:30,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,238 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,242 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,242 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CBFBA33B17ED4E58BC5F3C3547091AEB, ordinal: 0
2016-01-14 23:51:30,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,251 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 23:51:30,252 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBFBA33B17ED4E58BC5F3C3547091AEB, mem on start (mb), free: 156, total: 223, max: 672
2016-01-14 23:51:30,253 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBFBA33B17ED4E58BC5F3C3547091AEB, mem on close (mb), free: 156, total: 223, max: 672
2016-01-14 23:51:30,266 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-14 23:51:30,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.067
2016-01-14 23:51:30,302 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-14 23:51:30,309 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,309 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 23:51:30,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 23:51:30,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 23:51:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-14 23:51:30,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1366749398_0008
2016-01-14 23:51:30,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,397 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,404 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,416 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1949B66D0584A479310F9BD4C2DAECA, ordinal: 0
2016-01-14 23:51:30,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,417 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 23:51:30,417 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1949B66D0584A479310F9BD4C2DAECA, mem on start (mb), free: 259, total: 281, max: 672
2016-01-14 23:51:30,420 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1949B66D0584A479310F9BD4C2DAECA, mem on close (mb), free: 259, total: 281, max: 672
2016-01-14 23:51:30,435 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-14 23:51:30,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.085
2016-01-14 23:51:30,457 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-14 23:51:30,467 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,467 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 23:51:30,504 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 23:51:30,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 23:51:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 23:51:30,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local747273384_0009
2016-01-14 23:51:30,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,548 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,551 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE343E9455974C058524F95034F99035, ordinal: 0
2016-01-14 23:51:30,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 23:51:30,560 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE343E9455974C058524F95034F99035, mem on start (mb), free: 245, total: 281, max: 672
2016-01-14 23:51:30,562 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE343E9455974C058524F95034F99035, mem on close (mb), free: 245, total: 281, max: 672
2016-01-14 23:51:30,579 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-14 23:51:30,580 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.063
2016-01-14 23:51:30,594 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 23:51:30,602 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,603 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 23:51:30,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 23:51:30,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,635 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 23:51:30,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 23:51:30,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1910912998_0010
2016-01-14 23:51:30,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,683 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,695 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BB243FF30CCD434297A612CF223CB63E, ordinal: 0
2016-01-14 23:51:30,695 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 23:51:30,696 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB243FF30CCD434297A612CF223CB63E, mem on start (mb), free: 231, total: 281, max: 672
2016-01-14 23:51:30,697 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,700 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,702 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,703 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB243FF30CCD434297A612CF223CB63E, mem on close (mb), free: 230, total: 281, max: 672
2016-01-14 23:51:30,704 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1910912998_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,710 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1910912998_0010 state at FAILED
2016-01-14 23:51:30,710 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:30,711 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:30,711 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:30,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:30,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 23:51:30,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:30,712 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-14 23:51:30,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.066
2016-01-14 23:51:30,713 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-14 23:51:30,722 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,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 23:51:30,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.021
2016-01-14 23:51:30,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:30,748 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-14 23:51:30,754 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,754 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 23:51:30,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 23:51:30,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,807 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 23:51:30,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,809 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 23:51:30,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local279107163_0011
2016-01-14 23:51:30,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,840 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,844 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB07B81FD07841EF8CC6B47346E54F12, ordinal: 0
2016-01-14 23:51:30,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 23:51:30,852 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB07B81FD07841EF8CC6B47346E54F12, mem on start (mb), free: 216, total: 281, max: 672
2016-01-14 23:51:30,853 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,855 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,857 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB07B81FD07841EF8CC6B47346E54F12, mem on close (mb), free: 216, total: 281, max: 672
2016-01-14 23:51:30,859 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local279107163_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,868 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local279107163_0011 state at FAILED
2016-01-14 23:51:30,868 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:30,868 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:30,868 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:30,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:30,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 23:51:30,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:30,869 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-14 23:51:30,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.063
2016-01-14 23:51:30,870 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-14 23:51:30,876 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:30,877 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 23:51:30,906 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 23:51:30,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:30,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:30,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:30,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 23:51:30,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:30,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:30,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:30,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 23:51:30,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1826007382_0012
2016-01-14 23:51:30,958 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:30,963 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:30,969 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:30,970 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:30,981 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C2C80E5945DE4087A4DBBACB2BDD3CE6, ordinal: 0
2016-01-14 23:51:30,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:30,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 23:51:30,983 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C2C80E5945DE4087A4DBBACB2BDD3CE6, mem on start (mb), free: 205, total: 281, max: 672
2016-01-14 23:51:30,984 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,986 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,986 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,987 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C2C80E5945DE4087A4DBBACB2BDD3CE6, mem on close (mb), free: 204, total: 281, max: 672
2016-01-14 23:51:30,988 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1826007382_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:30,990 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1826007382_0012 state at FAILED
2016-01-14 23:51:30,990 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:30,990 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:30,990 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:30,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:30,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 23:51:30,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:30,997 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-14 23:51:30,998 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.081
2016-01-14 23:51:30,998 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-14 23:51:31,005 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,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 23:51:31,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2016-01-14 23:51:31,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:31,021 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-14 23:51:31,032 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,032 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 23:51:31,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 23:51:31,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 23:51:31,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-14 23:51:31,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1196172664_0013
2016-01-14 23:51:31,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,133 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD1AB30933684AEC887D9F4A0D7BE1B4, ordinal: 0
2016-01-14 23:51:31,146 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,146 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 23:51:31,147 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD1AB30933684AEC887D9F4A0D7BE1B4, mem on start (mb), free: 190, total: 281, max: 672
2016-01-14 23:51:31,150 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD1AB30933684AEC887D9F4A0D7BE1B4, mem on close (mb), free: 190, total: 281, max: 672
2016-01-14 23:51:31,176 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-14 23:51:31,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.092
2016-01-14 23:51:31,203 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-14 23:51:31,214 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,215 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 23:51:31,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-14 23:51:31,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:31,233 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-14 23:51:31,244 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,244 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 23:51:31,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 23:51:31,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 23:51:31,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-14 23:51:31,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1214387273_0014
2016-01-14 23:51:31,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,340 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,343 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,343 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,354 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6C4C755CD44403986B6C5C16C7F2238, ordinal: 0
2016-01-14 23:51:31,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 23:51:31,357 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6C4C755CD44403986B6C5C16C7F2238, mem on start (mb), free: 174, total: 281, max: 672
2016-01-14 23:51:31,360 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6C4C755CD44403986B6C5C16C7F2238, mem on close (mb), free: 174, total: 281, max: 672
2016-01-14 23:51:31,377 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-14 23:51:31,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.078
2016-01-14 23:51:31,396 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-14 23:51:31,403 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,403 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 23:51:31,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 23:51:31,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 23:51:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-14 23:51:31,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1061492206_0015
2016-01-14 23:51:31,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,478 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,482 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,482 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,488 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD8DC6B2118D45E99FAB68543E4D6C44, ordinal: 0
2016-01-14 23:51:31,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 23:51:31,489 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD8DC6B2118D45E99FAB68543E4D6C44, mem on start (mb), free: 159, total: 281, max: 672
2016-01-14 23:51:31,491 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD8DC6B2118D45E99FAB68543E4D6C44, mem on close (mb), free: 159, total: 281, max: 672
2016-01-14 23:51:31,506 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-14 23:51:31,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.062
2016-01-14 23:51:31,549 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-14 23:51:31,555 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,555 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 23:51:31,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 23:51:31,580 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,581 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 23:51:31,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-14 23:51:31,637 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1250517363_0016
2016-01-14 23:51:31,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,644 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,650 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,660 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E603AB0857BB4EB4B567FD9BFFD92264, ordinal: 0
2016-01-14 23:51:31,661 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,662 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 23:51:31,662 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E603AB0857BB4EB4B567FD9BFFD92264, mem on start (mb), free: 260, total: 281, max: 672
2016-01-14 23:51:31,666 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E603AB0857BB4EB4B567FD9BFFD92264, mem on close (mb), free: 260, total: 281, max: 672
2016-01-14 23:51:31,682 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-14 23:51:31,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.087
2016-01-14 23:51:31,704 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-14 23:51:31,713 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,713 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 23:51:31,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 23:51:31,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 23:51:31,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-14 23:51:31,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1344507470_0017
2016-01-14 23:51:31,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,792 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,795 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,795 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E4E93378D13E4212A0CACA905346D2A1, ordinal: 0
2016-01-14 23:51:31,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,802 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 23:51:31,803 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4E93378D13E4212A0CACA905346D2A1, mem on start (mb), free: 246, total: 281, max: 672
2016-01-14 23:51:31,805 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4E93378D13E4212A0CACA905346D2A1, mem on close (mb), free: 246, total: 281, max: 672
2016-01-14 23:51:31,820 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-14 23:51:31,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.060
2016-01-14 23:51:31,834 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-14 23:51:31,840 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,840 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 23:51:31,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 23:51:31,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:31,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:31,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:31,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 23:51:31,881 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:31,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:31,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:31,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-14 23:51:31,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local888154194_0018
2016-01-14 23:51:31,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:31,921 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:31,923 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:31,924 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:31,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B0D2678ECB584B98892A220361919A9D, ordinal: 0
2016-01-14 23:51:31,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:31,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 23:51:31,931 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0D2678ECB584B98892A220361919A9D, mem on start (mb), free: 231, total: 281, max: 672
2016-01-14 23:51:31,934 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0D2678ECB584B98892A220361919A9D, mem on close (mb), free: 231, total: 281, max: 672
2016-01-14 23:51:31,942 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-14 23:51:31,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.062
2016-01-14 23:51:31,961 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-14 23:51:31,970 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,970 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 23:51:31,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-14 23:51:31,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:31,989 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-14 23:51:31,997 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:31,998 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 23:51:32,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 23:51:32,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 23:51:32,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-14 23:51:32,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local795518785_0019
2016-01-14 23:51:32,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,062 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED6F57A5E5F746F7A0679AE36996C96D, ordinal: 0
2016-01-14 23:51:32,071 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,072 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 23:51:32,072 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED6F57A5E5F746F7A0679AE36996C96D, mem on start (mb), free: 214, total: 281, max: 672
2016-01-14 23:51:32,074 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED6F57A5E5F746F7A0679AE36996C96D, mem on close (mb), free: 214, total: 281, max: 672
2016-01-14 23:51:32,091 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-14 23:51:32,091 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.056
2016-01-14 23:51:32,104 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-14 23:51:32,109 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,110 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 23:51:32,132 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 23:51:32,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 23:51:32,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-14 23:51:32,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local375140938_0020
2016-01-14 23:51:32,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,183 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,186 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,186 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE8AFEB7A077487CA89EE949ACB6575D, ordinal: 0
2016-01-14 23:51:32,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 23:51:32,192 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE8AFEB7A077487CA89EE949ACB6575D, mem on start (mb), free: 199, total: 281, max: 672
2016-01-14 23:51:32,194 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE8AFEB7A077487CA89EE949ACB6575D, mem on close (mb), free: 199, total: 281, max: 672
2016-01-14 23:51:32,211 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-14 23:51:32,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.066
2016-01-14 23:51:32,225 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-14 23:51:32,232 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,232 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 23:51:32,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:32,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 23:51:32,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 23:51:32,287 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1343937216_0021
2016-01-14 23:51:32,288 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,292 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7D39D2A17EA4C19832F97EED916E457, ordinal: 0
2016-01-14 23:51:32,305 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,305 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 23:51:32,305 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7D39D2A17EA4C19832F97EED916E457, mem on start (mb), free: 185, total: 281, max: 672
2016-01-14 23:51:32,306 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,306 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,307 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,307 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7D39D2A17EA4C19832F97EED916E457, mem on close (mb), free: 184, total: 281, max: 672
2016-01-14 23:51:32,308 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1343937216_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,319 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1343937216_0021 state at FAILED
2016-01-14 23:51:32,319 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:32,319 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:32,319 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:32,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:32,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 23:51:32,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:32,320 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-14 23:51:32,321 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.062
2016-01-14 23:51:32,321 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-14 23:51:32,329 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,330 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 23:51:32,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-01-14 23:51:32,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:32,341 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-14 23:51:32,347 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,348 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 23:51:32,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 23:51:32,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 23:51:32,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 23:51:32,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1356044958_0022
2016-01-14 23:51:32,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,415 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,425 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1825B48644042F29419003F1B300DCE, ordinal: 0
2016-01-14 23:51:32,425 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,426 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 23:51:32,426 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1825B48644042F29419003F1B300DCE, mem on start (mb), free: 171, total: 281, max: 672
2016-01-14 23:51:32,427 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,432 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,438 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,444 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1825B48644042F29419003F1B300DCE, mem on close (mb), free: 170, total: 281, max: 672
2016-01-14 23:51:32,445 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1356044958_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,454 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1356044958_0022 state at FAILED
2016-01-14 23:51:32,454 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:32,454 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:32,454 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:32,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:32,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 23:51:32,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:32,455 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-14 23:51:32,456 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.069
2016-01-14 23:51:32,456 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-14 23:51:32,462 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,462 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 23:51:32,483 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 23:51:32,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 23:51:32,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 23:51:32,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local923376388_0023
2016-01-14 23:51:32,523 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,527 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,531 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,531 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2C00480E6C5461395E27148743AFBC3, ordinal: 0
2016-01-14 23:51:32,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 23:51:32,541 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2C00480E6C5461395E27148743AFBC3, mem on start (mb), free: 159, total: 281, max: 672
2016-01-14 23:51:32,541 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,542 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,543 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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,543 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2C00480E6C5461395E27148743AFBC3, mem on close (mb), free: 158, total: 281, max: 672
2016-01-14 23:51:32,551 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local923376388_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 23:51:32,555 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local923376388_0023 state at FAILED
2016-01-14 23:51:32,555 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 23:51:32,556 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 23:51:32,556 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 23:51:32,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 23:51:32,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 23:51:32,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 23:51:32,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-14 23:51:32,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.064
2016-01-14 23:51:32,558 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-14 23:51:32,567 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,567 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 23:51:32,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 23:51:32,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,617 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 23:51:32,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-14 23:51:32,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local862690185_0024
2016-01-14 23:51:32,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,660 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BD7E16BD3C0E4CBB85CE31A2818F4A80, ordinal: 0
2016-01-14 23:51:32,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 23:51:32,669 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD7E16BD3C0E4CBB85CE31A2818F4A80, mem on start (mb), free: 372, total: 396, max: 672
2016-01-14 23:51:32,671 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD7E16BD3C0E4CBB85CE31A2818F4A80, mem on close (mb), free: 372, total: 396, max: 672
2016-01-14 23:51:32,678 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-14 23:51:32,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.052
2016-01-14 23:51:32,692 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-14 23:51:32,700 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,701 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 23:51:32,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 23:51:32,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:32,711 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-14 23:51:32,716 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,717 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 23:51:32,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 23:51:32,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,742 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 23:51:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-14 23:51:32,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local909782059_0025
2016-01-14 23:51:32,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,775 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,783 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2CC8CE50DB64F4885AA22C8A73DB571, ordinal: 0
2016-01-14 23:51:32,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 23:51:32,784 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2CC8CE50DB64F4885AA22C8A73DB571, mem on start (mb), free: 353, total: 396, max: 672
2016-01-14 23:51:32,786 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2CC8CE50DB64F4885AA22C8A73DB571, mem on close (mb), free: 353, total: 396, max: 672
2016-01-14 23:51:32,794 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-14 23:51:32,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.045
2016-01-14 23:51:32,807 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-14 23:51:32,812 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,813 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 23:51:32,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-14 23:51:32,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:32,823 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-14 23:51:32,829 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,830 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 23:51:32,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:32,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,848 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 23:51:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,856 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-14 23:51:32,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1933388_0026
2016-01-14 23:51:32,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,880 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,883 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,883 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,888 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D99EF7FC0340449D863C7E0A37561110, ordinal: 0
2016-01-14 23:51:32,889 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,889 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 23:51:32,890 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D99EF7FC0340449D863C7E0A37561110, mem on start (mb), free: 334, total: 396, max: 672
2016-01-14 23:51:32,892 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D99EF7FC0340449D863C7E0A37561110, mem on close (mb), free: 334, total: 396, max: 672
2016-01-14 23:51:32,908 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-14 23:51:32,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.054
2016-01-14 23:51:32,921 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-14 23:51:32,927 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:32,927 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 23:51:32,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 23:51:32,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:32,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:32,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:32,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 23:51:32,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:32,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:32,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:32,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-14 23:51:32,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local901667773_0027
2016-01-14 23:51:32,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:32,985 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:32,988 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:32,988 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:32,993 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C0B35490F679413BB97B0EEEE8A24621, ordinal: 0
2016-01-14 23:51:32,994 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:32,994 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 23:51:32,994 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C0B35490F679413BB97B0EEEE8A24621, mem on start (mb), free: 317, total: 396, max: 672
2016-01-14 23:51:32,997 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C0B35490F679413BB97B0EEEE8A24621, mem on close (mb), free: 317, total: 396, max: 672
2016-01-14 23:51:33,013 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-14 23:51:33,014 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.054
2016-01-14 23:51:33,026 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-14 23:51:33,033 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:33,033 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 23:51:33,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:33,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:33,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:33,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:33,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 23:51:33,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:33,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:33,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:33,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-14 23:51:33,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2062815154_0028
2016-01-14 23:51:33,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:33,083 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:33,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:33,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:33,090 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B9CADE09C6C747F1A51D1D464A5AB1A5, ordinal: 0
2016-01-14 23:51:33,091 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,091 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 23:51:33,091 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9CADE09C6C747F1A51D1D464A5AB1A5, mem on start (mb), free: 300, total: 396, max: 672
2016-01-14 23:51:33,093 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9CADE09C6C747F1A51D1D464A5AB1A5, mem on close (mb), free: 300, total: 396, max: 672
2016-01-14 23:51:33,101 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-14 23:51:33,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.043
2016-01-14 23:51:33,115 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-14 23:51:33,121 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:33,121 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 23:51:33,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:33,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:33,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:33,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:33,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 23:51:33,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:33,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:33,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:33,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-14 23:51:33,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1276191785_0029
2016-01-14 23:51:33,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:33,173 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:33,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:33,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:33,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8D9C87730774A7A95F8F11CBC6A149A, ordinal: 0
2016-01-14 23:51:33,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 23:51:33,184 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8D9C87730774A7A95F8F11CBC6A149A, mem on start (mb), free: 283, total: 396, max: 672
2016-01-14 23:51:33,186 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8D9C87730774A7A95F8F11CBC6A149A, mem on close (mb), free: 283, total: 396, max: 672
2016-01-14 23:51:33,194 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-14 23:51:33,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.047
2016-01-14 23:51:33,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-14 23:51:33,213 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:33,213 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 23:51:33,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:33,238 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:33,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 23:51:33,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:33,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:33,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:33,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-14 23:51:33,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1691440823_0030
2016-01-14 23:51:33,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:33,266 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:33,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:33,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:33,276 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA66FCFD064A40B2956AD0AC7B8FB095, ordinal: 0
2016-01-14 23:51:33,276 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,276 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 23:51:33,277 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA66FCFD064A40B2956AD0AC7B8FB095, mem on start (mb), free: 267, total: 396, max: 672
2016-01-14 23:51:33,279 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA66FCFD064A40B2956AD0AC7B8FB095, mem on close (mb), free: 267, total: 396, max: 672
2016-01-14 23:51:33,294 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-14 23:51:33,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.056
2016-01-14 23:51:33,308 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-14 23:51:33,313 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:33,313 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 23:51:33,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 23:51:33,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 23:51:33,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:51:33,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 23:51:33,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 23:51:33,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 23:51:33,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 23:51:33,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 23:51:33,342 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 23:51:33,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1255096398_0031
2016-01-14 23:51:33,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 23:51:33,369 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt
2016-01-14 23:51:33,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:51:33,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:51:33,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C443B576A3D14261BE22DF805C9A63EB, ordinal: 0
2016-01-14 23:51:33,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2016-01-14 23:51:33,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 23:51:33,378 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C443B576A3D14261BE22DF805C9A63EB, mem on start (mb), free: 251, total: 396, max: 672
2016-01-14 23:51:33,380 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C443B576A3D14261BE22DF805C9A63EB, mem on close (mb), free: 251, total: 396, max: 672
2016-01-14 23:51:33,397 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-14 23:51:33,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.058
2016-01-14 23:51:33,414 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 23:51:33,421 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:51:33,422 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 23:51:33,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 23:51:33,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:51:33,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'