2016-01-14 17:50:01,186 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:50:01,203 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EveryEveryPipeAssemblyPlatformTest, with platform: hadoop
2016-01-14 17:50:01,631 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 17:50:01,848 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 17:50:01,919 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:01,921 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 17:50:02,040 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 8DBBBDB64F9E4FABA1D5462729DEE38E
2016-01-14 17:50:02,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-01-14 17:50:02,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:02,166 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 17:50:02,340 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:50:02,342 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:02,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:02,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 17:50:02,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:02,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:02,346 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:02,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-14 17:50:02,390 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 17:50:02,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0001
2016-01-14 17:50:02,650 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:02,711 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:02,724 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:02,724 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:02,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5634A586E4F4011B99A5762DF1BD9CC, ordinal: 0
2016-01-14 17:50:02,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:02,779 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 17:50:02,780 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5634A586E4F4011B99A5762DF1BD9CC, mem on start (mb), free: 243, total: 281, max: 672
2016-01-14 17:50:02,790 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5634A586E4F4011B99A5762DF1BD9CC, mem on close (mb), free: 243, total: 281, max: 672
2016-01-14 17:50:05,699 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-14 17:50:05,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.356
2016-01-14 17:50:05,747 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-14 17:50:05,766 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:05,766 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 17:50:05,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2016-01-14 17:50:05,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:05,849 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 17:50:05,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:05,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:05,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 17:50:05,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:05,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:05,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:05,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-14 17:50:05,973 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0002
2016-01-14 17:50:05,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:05,980 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:05,987 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:05,987 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:06,006 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E576A170F2F84A1D8236F7D30FDF415F, ordinal: 0
2016-01-14 17:50:06,007 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:06,008 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 17:50:06,008 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E576A170F2F84A1D8236F7D30FDF415F, mem on start (mb), free: 231, total: 281, max: 672
2016-01-14 17:50:06,011 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E576A170F2F84A1D8236F7D30FDF415F, mem on close (mb), free: 231, total: 281, max: 672
2016-01-14 17:50:08,987 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-14 17:50:08,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.122
2016-01-14 17:50:09,021 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-14 17:50:09,041 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:09,042 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 17:50:09,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 17:50:09,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:09,118 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 17:50:09,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:09,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:09,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 17:50:09,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:09,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:09,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:09,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-14 17:50:09,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0003
2016-01-14 17:50:09,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:09,235 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:09,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:09,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:09,258 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F081D0D40D424F0AB40374ABC4DFC151, ordinal: 0
2016-01-14 17:50:09,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:09,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 17:50:09,260 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F081D0D40D424F0AB40374ABC4DFC151, mem on start (mb), free: 219, total: 281, max: 672
2016-01-14 17:50:09,263 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F081D0D40D424F0AB40374ABC4DFC151, mem on close (mb), free: 219, total: 281, max: 672
2016-01-14 17:50:12,247 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-14 17:50:12,248 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.111
2016-01-14 17:50:12,270 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-14 17:50:12,278 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:12,279 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 17:50:12,333 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-14 17:50:12,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:12,335 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 17:50:12,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:12,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:12,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 17:50:12,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:12,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:12,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:12,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-14 17:50:12,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0004
2016-01-14 17:50:12,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:12,400 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:12,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:12,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:12,414 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB5952EB315849CE9B3066E25F137324, ordinal: 0
2016-01-14 17:50:12,415 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:12,415 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 17:50:12,415 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB5952EB315849CE9B3066E25F137324, mem on start (mb), free: 208, total: 281, max: 672
2016-01-14 17:50:12,417 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB5952EB315849CE9B3066E25F137324, mem on close (mb), free: 208, total: 281, max: 672
2016-01-14 17:50:15,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-14 17:50:15,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.062
2016-01-14 17:50:15,429 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-14 17:50:15,439 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:15,439 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:50:15,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 17:50:15,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:15,481 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 17:50:15,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:15,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:15,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 17:50:15,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:15,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:15,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:15,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-14 17:50:15,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0005
2016-01-14 17:50:15,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:15,545 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:15,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:15,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:15,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9B56F1BA4E74CB699A8064BBD90B2DF, ordinal: 0
2016-01-14 17:50:15,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:15,561 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 17:50:15,561 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9B56F1BA4E74CB699A8064BBD90B2DF, mem on start (mb), free: 196, total: 281, max: 672
2016-01-14 17:50:15,563 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9B56F1BA4E74CB699A8064BBD90B2DF, mem on close (mb), free: 196, total: 281, max: 672
2016-01-14 17:50:18,548 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-14 17:50:18,549 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.053
2016-01-14 17:50:18,568 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-14 17:50:18,577 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:18,577 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 17:50:18,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 17:50:18,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:18,616 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 17:50:18,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:18,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:18,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 17:50:18,629 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:18,630 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:18,630 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:18,630 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-14 17:50:18,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0006
2016-01-14 17:50:18,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:18,679 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:18,685 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:18,685 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:18,694 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CEFA480FC8874E0E9F36DAB1756CFB1D, ordinal: 0
2016-01-14 17:50:18,695 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:18,695 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 17:50:18,695 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEFA480FC8874E0E9F36DAB1756CFB1D, mem on start (mb), free: 184, total: 281, max: 672
2016-01-14 17:50:18,698 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CEFA480FC8874E0E9F36DAB1756CFB1D, mem on close (mb), free: 184, total: 281, max: 672
2016-01-14 17:50:21,690 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-14 17:50:21,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.062
2016-01-14 17:50:21,709 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-14 17:50:21,717 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:21,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 17:50:21,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-01-14 17:50:21,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:21,735 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-14 17:50:21,743 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:21,743 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 17:50:21,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 17:50:21,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:21,782 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 17:50:21,792 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:21,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:21,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 17:50:21,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:21,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:21,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:21,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-14 17:50:21,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0007
2016-01-14 17:50:21,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:21,834 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:21,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:21,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:21,847 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FA0F36E301BB4534A2D449A3FED58C95, ordinal: 0
2016-01-14 17:50:21,847 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:21,848 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 17:50:21,848 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA0F36E301BB4534A2D449A3FED58C95, mem on start (mb), free: 172, total: 281, max: 672
2016-01-14 17:50:21,851 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA0F36E301BB4534A2D449A3FED58C95, mem on close (mb), free: 172, total: 281, max: 672
2016-01-14 17:50:24,841 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-14 17:50:24,841 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.048
2016-01-14 17:50:24,860 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-14 17:50:24,871 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:24,871 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 17:50:24,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 17:50:24,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:24,911 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 17:50:24,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:24,922 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:24,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 17:50:24,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:24,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:24,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:24,924 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-14 17:50:24,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0008
2016-01-14 17:50:24,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:24,961 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:24,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:24,967 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:24,980 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AEC0750AC54A4AAFBB93E3FC8621D33A, ordinal: 0
2016-01-14 17:50:24,981 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:24,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 17:50:24,982 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC0750AC54A4AAFBB93E3FC8621D33A, mem on start (mb), free: 160, total: 281, max: 672
2016-01-14 17:50:24,985 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC0750AC54A4AAFBB93E3FC8621D33A, mem on close (mb), free: 160, total: 281, max: 672
2016-01-14 17:50:27,980 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-14 17:50:27,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.059
2016-01-14 17:50:28,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-14 17:50:28,024 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:28,025 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 17:50:28,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 17:50:28,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:28,063 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 17:50:28,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:28,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:28,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 17:50:28,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:28,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:28,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:28,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 17:50:28,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0009
2016-01-14 17:50:28,121 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:28,129 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:28,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:28,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:28,148 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE42205CF92345C58C0BFBFAD41155F6, ordinal: 0
2016-01-14 17:50:28,149 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:28,149 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 17:50:28,149 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE42205CF92345C58C0BFBFAD41155F6, mem on start (mb), free: 258, total: 281, max: 672
2016-01-14 17:50:28,152 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE42205CF92345C58C0BFBFAD41155F6, mem on close (mb), free: 258, total: 281, max: 672
2016-01-14 17:50:31,134 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-14 17:50:31,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.059
2016-01-14 17:50:31,149 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 17:50:31,154 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,155 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 17:50:31,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 17:50:31,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:31,183 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 17:50:31,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:31,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 17:50:31,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:31,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:31,194 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:31,195 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 17:50:31,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0010
2016-01-14 17:50:31,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:31,228 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:31,232 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:31,232 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:31,240 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDFEC49F75B44590B224523DB3D15556, ordinal: 0
2016-01-14 17:50:31,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 17:50:31,241 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDFEC49F75B44590B224523DB3D15556, mem on start (mb), free: 248, total: 281, max: 672
2016-01-14 17:50:31,243 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,247 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,249 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,251 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDFEC49F75B44590B224523DB3D15556, mem on close (mb), free: 248, total: 281, max: 672
2016-01-14 17:50:31,252 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,255 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0010 state at FAILED
2016-01-14 17:50:31,255 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:31,257 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:31,257 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:31,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:31,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 17:50:31,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:31,258 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-14 17:50:31,259 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.065
2016-01-14 17:50:31,259 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-14 17:50:31,265 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,265 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 17:50:31,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-01-14 17:50:31,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:31,280 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-14 17:50:31,288 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,288 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 17:50:31,322 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 17:50:31,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:31,323 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 17:50:31,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:31,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 17:50:31,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:31,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:31,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:31,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 17:50:31,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0011
2016-01-14 17:50:31,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:31,367 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:31,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:31,371 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:31,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DD02927243124305835AD7A024311BBF, ordinal: 0
2016-01-14 17:50:31,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 17:50:31,379 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD02927243124305835AD7A024311BBF, mem on start (mb), free: 237, total: 281, max: 672
2016-01-14 17:50:31,380 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,385 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,391 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,392 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD02927243124305835AD7A024311BBF, mem on close (mb), free: 237, total: 281, max: 672
2016-01-14 17:50:31,393 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0011 state at FAILED
2016-01-14 17:50:31,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:31,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:31,394 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:31,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:31,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 17:50:31,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:31,398 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-14 17:50:31,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.063
2016-01-14 17:50:31,398 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-14 17:50:31,405 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,405 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 17:50:31,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:50:31,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50: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 17:50:31,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:31,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 17:50:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:31,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 17:50:31,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0012
2016-01-14 17:50:31,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:31,471 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:31,478 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:31,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:31,491 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C4A49072385542D0978C7B666730B58D, ordinal: 0
2016-01-14 17:50:31,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,492 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 17:50:31,492 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4A49072385542D0978C7B666730B58D, mem on start (mb), free: 228, total: 281, max: 672
2016-01-14 17:50:31,493 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,496 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,497 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,503 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4A49072385542D0978C7B666730B58D, mem on close (mb), free: 228, total: 281, max: 672
2016-01-14 17:50:31,504 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0012
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:31,509 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0012 state at FAILED
2016-01-14 17:50:31,509 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:31,509 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:31,510 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:31,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:31,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 17:50:31,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:31,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutting down job executor
2016-01-14 17:50:31,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutdown complete
2016-01-14 17:50:31,512 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-14 17:50:31,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.068
2016-01-14 17:50:31,513 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-14 17:50:31,521 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,521 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 17:50:31,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-14 17:50:31,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:31,534 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-14 17:50:31,541 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:31,541 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 17:50:31,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:50:31,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:31,566 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 17:50:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 17:50:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:31,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:31,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:31,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-14 17:50:31,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0013
2016-01-14 17:50:31,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:31,605 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:31,608 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:31,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:31,615 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2B278FF094A4074928079CF8F0A436B, ordinal: 0
2016-01-14 17:50:31,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:31,616 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 17:50:31,616 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B278FF094A4074928079CF8F0A436B, mem on start (mb), free: 218, total: 281, max: 672
2016-01-14 17:50:31,618 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2B278FF094A4074928079CF8F0A436B, mem on close (mb), free: 218, total: 281, max: 672
2016-01-14 17:50:34,614 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-14 17:50:34,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.039
2016-01-14 17:50:34,628 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-14 17:50:34,634 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:34,635 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 17:50:34,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-14 17:50:34,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:34,646 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-14 17:50:34,652 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:34,653 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 17:50:34,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:50:34,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:34,675 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 17:50:34,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:34,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:34,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 17:50:34,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:34,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:34,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:34,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-14 17:50:34,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0014
2016-01-14 17:50:34,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:34,750 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:34,755 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:34,756 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:34,768 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D155583055D543B3A2E7113ED72B712B, ordinal: 0
2016-01-14 17:50:34,769 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:34,770 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 17:50:34,770 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D155583055D543B3A2E7113ED72B712B, mem on start (mb), free: 203, total: 281, max: 672
2016-01-14 17:50:34,774 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D155583055D543B3A2E7113ED72B712B, mem on close (mb), free: 203, total: 281, max: 672
2016-01-14 17:50:37,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-14 17:50:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.074
2016-01-14 17:50:37,774 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-14 17:50:37,781 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:37,781 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 17:50:37,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:50:37,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:37,813 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 17:50:37,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:37,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:37,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 17:50:37,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:37,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:37,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:37,825 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-14 17:50:37,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0015
2016-01-14 17:50:37,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:37,851 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:37,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:37,854 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:37,863 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF35830A4D7A42F5A7DA64B1376A7F8D, ordinal: 0
2016-01-14 17:50:37,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:37,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 17:50:37,864 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF35830A4D7A42F5A7DA64B1376A7F8D, mem on start (mb), free: 191, total: 281, max: 672
2016-01-14 17:50:37,866 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF35830A4D7A42F5A7DA64B1376A7F8D, mem on close (mb), free: 191, total: 281, max: 672
2016-01-14 17:50:40,853 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-14 17:50:40,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.029
2016-01-14 17:50:40,867 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-14 17:50:40,873 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:40,873 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 17:50:40,905 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:50:40,906 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:40,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 17:50:40,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:40,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:40,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 17:50:40,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:40,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:40,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:40,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-14 17:50:40,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0016
2016-01-14 17:50:40,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:40,951 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:40,956 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:40,957 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:40,963 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C50C41EBCC9C411F9D130F6E1BCF7BC5, ordinal: 0
2016-01-14 17:50:40,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:40,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 17:50:40,964 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C50C41EBCC9C411F9D130F6E1BCF7BC5, mem on start (mb), free: 180, total: 281, max: 672
2016-01-14 17:50:40,966 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C50C41EBCC9C411F9D130F6E1BCF7BC5, mem on close (mb), free: 180, total: 281, max: 672
2016-01-14 17:50:43,952 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-14 17:50:43,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.035
2016-01-14 17:50:43,966 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-14 17:50:43,972 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:43,972 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 17:50:44,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:50:44,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:44,004 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 17:50:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 17:50:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:44,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:44,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:44,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-14 17:50:44,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0017
2016-01-14 17:50:44,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:44,052 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:44,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:44,056 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:44,066 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D990453E814F4CC794E0AB525301B96C, ordinal: 0
2016-01-14 17:50:44,066 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:44,067 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 17:50:44,067 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D990453E814F4CC794E0AB525301B96C, mem on start (mb), free: 170, total: 281, max: 672
2016-01-14 17:50:44,070 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D990453E814F4CC794E0AB525301B96C, mem on close (mb), free: 170, total: 281, max: 672
2016-01-14 17:50:47,054 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-14 17:50:47,055 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.036
2016-01-14 17:50:47,068 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-14 17:50:47,073 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:47,073 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 17:50:47,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:50:47,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:47,095 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 17:50:47,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:47,103 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 17:50:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:47,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:47,105 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-14 17:50:47,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0018
2016-01-14 17:50:47,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:47,130 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:47,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:47,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:47,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B16E2D2F59664E23B845FF6399B71624, ordinal: 0
2016-01-14 17:50:47,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:47,140 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 17:50:47,141 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B16E2D2F59664E23B845FF6399B71624, mem on start (mb), free: 158, total: 281, max: 672
2016-01-14 17:50:47,143 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B16E2D2F59664E23B845FF6399B71624, mem on close (mb), free: 158, total: 281, max: 672
2016-01-14 17:50:50,133 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-14 17:50:50,133 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.030
2016-01-14 17:50:50,145 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-14 17:50:50,152 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:50,152 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 17:50:50,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.015
2016-01-14 17:50:50,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:50,181 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-14 17:50:50,188 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:50,189 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 17:50:50,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:50:50,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:50,218 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 17:50:50,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:50,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:50,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 17:50:50,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:50,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:50,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:50,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-14 17:50:50,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0019
2016-01-14 17:50:50,251 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:50,253 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:50,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:50,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:50,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDBBA6C9DC33450BBBFD6048CC4F82DF, ordinal: 0
2016-01-14 17:50:50,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:50,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 17:50:50,263 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBBA6C9DC33450BBBFD6048CC4F82DF, mem on start (mb), free: 263, total: 281, max: 672
2016-01-14 17:50:50,264 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDBBA6C9DC33450BBBFD6048CC4F82DF, mem on close (mb), free: 263, total: 281, max: 672
2016-01-14 17:50:53,264 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-14 17:50:53,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.037
2016-01-14 17:50:53,278 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-14 17:50:53,283 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:53,284 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 17:50:53,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:50:53,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:53,306 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 17:50:53,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:53,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:53,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 17:50:53,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:53,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:53,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:53,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-14 17:50:53,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0020
2016-01-14 17:50:53,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:53,354 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:53,358 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:53,359 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:53,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E132660989584A2BAAA22AEBBA508622, ordinal: 0
2016-01-14 17:50:53,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:53,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 17:50:53,370 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E132660989584A2BAAA22AEBBA508622, mem on start (mb), free: 252, total: 281, max: 672
2016-01-14 17:50:53,373 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E132660989584A2BAAA22AEBBA508622, mem on close (mb), free: 252, total: 281, max: 672
2016-01-14 17:50:56,356 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-14 17:50:56,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.038
2016-01-14 17:50:56,369 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-14 17:50:56,375 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:56,376 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 17:50:56,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 17:50:56,407 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:56,407 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 17:50:56,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:56,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 17:50:56,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:56,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:56,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:56,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 17:50:56,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0021
2016-01-14 17:50:56,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:56,438 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:56,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:56,440 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:56,449 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABB0B083457946C7B123199068A8C9F9, ordinal: 0
2016-01-14 17:50:56,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 17:50:56,452 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABB0B083457946C7B123199068A8C9F9, mem on start (mb), free: 241, total: 281, max: 672
2016-01-14 17:50:56,452 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,453 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,459 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,462 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABB0B083457946C7B123199068A8C9F9, mem on close (mb), free: 241, total: 281, max: 672
2016-01-14 17:50:56,463 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0021
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,472 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0021 state at FAILED
2016-01-14 17:50:56,472 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:56,472 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:56,472 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:56,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:56,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 17:50:56,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:56,473 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-14 17:50:56,474 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.059
2016-01-14 17:50:56,474 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-14 17:50:56,479 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:56,480 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 17:50:56,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-14 17:50:56,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:56,491 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-14 17:50:56,500 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:56,500 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 17:50:56,521 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:50:56,525 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:56,525 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 17:50:56,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:56,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 17:50:56,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:56,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:56,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:56,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 17:50:56,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0022
2016-01-14 17:50:56,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:56,570 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:56,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:56,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:56,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7FE2F5BBF8B484E85DECE8A260FECBD, ordinal: 0
2016-01-14 17:50:56,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 17:50:56,583 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7FE2F5BBF8B484E85DECE8A260FECBD, mem on start (mb), free: 231, total: 281, max: 672
2016-01-14 17:50:56,584 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,584 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,585 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,586 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7FE2F5BBF8B484E85DECE8A260FECBD, mem on close (mb), free: 231, total: 281, max: 672
2016-01-14 17:50:56,587 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0022
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,589 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0022 state at FAILED
2016-01-14 17:50:56,589 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:56,589 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:56,589 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:56,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:56,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 17:50:56,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:56,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutting down job executor
2016-01-14 17:50:56,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutdown complete
2016-01-14 17:50:56,590 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-14 17:50:56,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.054
2016-01-14 17:50:56,591 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-14 17:50:56,599 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:56,599 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 17:50:56,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:50:56,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:56,628 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 17:50:56,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:56,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 17:50:56,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:56,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:56,641 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:56,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 17:50:56,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0023
2016-01-14 17:50:56,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:56,664 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:56,666 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:56,666 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:56,671 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2FF80347B664D6A88A7FCBA21367D2F, ordinal: 0
2016-01-14 17:50:56,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,672 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 17:50:56,672 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2FF80347B664D6A88A7FCBA21367D2F, mem on start (mb), free: 222, total: 281, max: 672
2016-01-14 17:50:56,672 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,673 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,674 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,674 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2FF80347B664D6A88A7FCBA21367D2F, mem on close (mb), free: 222, total: 281, max: 672
2016-01-14 17:50:56,675 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0023
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
at cascading.TestFunction.operate(TestFunction.java:86)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2016-01-14 17:50:56,682 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local_0023 state at FAILED
2016-01-14 17:50:56,682 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2016-01-14 17:50:56,682 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2016-01-14 17:50:56,682 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2016-01-14 17:50:56,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2016-01-14 17:50:56,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 17:50:56,683 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2016-01-14 17:50:56,684 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-14 17:50:56,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:00.046
2016-01-14 17:50:56,685 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-14 17:50:56,693 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:56,693 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 17:50:56,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:50:56,718 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:56,718 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 17:50:56,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:56,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 17:50:56,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:56,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:56,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:56,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-14 17:50:56,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0024
2016-01-14 17:50:56,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:56,750 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:56,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:56,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:56,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABE269822A2B4F7399AAC5919487BFC7, ordinal: 0
2016-01-14 17:50:56,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:56,761 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 17:50:56,761 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE269822A2B4F7399AAC5919487BFC7, mem on start (mb), free: 213, total: 281, max: 672
2016-01-14 17:50:56,763 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE269822A2B4F7399AAC5919487BFC7, mem on close (mb), free: 213, total: 281, max: 672
2016-01-14 17:50:59,752 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-14 17:50:59,753 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.027
2016-01-14 17:50:59,765 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-14 17:50:59,771 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:59,771 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 17:50:59,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-01-14 17:50:59,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:50:59,781 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-14 17:50:59,787 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:50:59,788 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 17:50:59,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:50:59,809 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:50:59,809 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 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:50:59,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:50:59,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-14 17:50:59,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0025
2016-01-14 17:50:59,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:50:59,840 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:50:59,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:50:59,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:50:59,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BB48F6F07C984285B9E2677AC6C6F17D, ordinal: 0
2016-01-14 17:50:59,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:50:59,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 17:50:59,851 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB48F6F07C984285B9E2677AC6C6F17D, mem on start (mb), free: 200, total: 281, max: 672
2016-01-14 17:50:59,853 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB48F6F07C984285B9E2677AC6C6F17D, mem on close (mb), free: 200, total: 281, max: 672
2016-01-14 17:51:02,851 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-14 17:51:02,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.034
2016-01-14 17:51:02,863 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-14 17:51:02,869 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:02,869 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 17:51:02,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 17:51:02,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:51:02,878 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-14 17:51:02,883 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:02,884 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 17:51:02,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:51:02,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:02,902 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 17:51:02,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:02,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:02,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 17:51:02,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:02,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:02,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:02,911 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-14 17:51:02,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0026
2016-01-14 17:51:02,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:02,934 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:02,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:02,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:02,942 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A66EB131A3114F58B63515363E52C13F, ordinal: 0
2016-01-14 17:51:02,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:02,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 17:51:02,943 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A66EB131A3114F58B63515363E52C13F, mem on start (mb), free: 184, total: 281, max: 672
2016-01-14 17:51:02,946 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A66EB131A3114F58B63515363E52C13F, mem on close (mb), free: 184, total: 281, max: 672
2016-01-14 17:51:05,945 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-14 17:51:05,945 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.036
2016-01-14 17:51:05,957 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-14 17:51:05,962 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:05,962 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 17:51:05,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 17:51:05,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:05,981 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 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:05,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:05,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-14 17:51:06,008 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0027
2016-01-14 17:51:06,008 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:06,011 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:06,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:06,014 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:06,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DFA0C5FB9A994FD2908B4BA720AC842E, ordinal: 0
2016-01-14 17:51:06,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:06,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 17:51:06,021 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFA0C5FB9A994FD2908B4BA720AC842E, mem on start (mb), free: 174, total: 281, max: 672
2016-01-14 17:51:06,024 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFA0C5FB9A994FD2908B4BA720AC842E, mem on close (mb), free: 174, total: 281, max: 672
2016-01-14 17:51:09,015 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-14 17:51:09,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.027
2016-01-14 17:51:09,028 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-14 17:51:09,033 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:09,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 17:51:09,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 17:51:09,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:09,053 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 17:51:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 17:51:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:09,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-14 17:51:09,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0028
2016-01-14 17:51:09,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:09,085 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:09,087 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:09,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:09,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB171DF08A9E4B61BA413B53B6B8D01F, ordinal: 0
2016-01-14 17:51:09,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:09,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 17:51:09,093 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB171DF08A9E4B61BA413B53B6B8D01F, mem on start (mb), free: 163, total: 281, max: 672
2016-01-14 17:51:09,095 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB171DF08A9E4B61BA413B53B6B8D01F, mem on close (mb), free: 163, total: 281, max: 672
2016-01-14 17:51:12,093 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-14 17:51:12,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.029
2016-01-14 17:51:12,105 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-14 17:51:12,109 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:12,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 17:51:12,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:51:12,127 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:12,127 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 17:51:12,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:12,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:12,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 17:51:12,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:12,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:12,139 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:12,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-14 17:51:12,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0029
2016-01-14 17:51:12,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:12,180 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:12,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:12,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:12,190 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5647330688B493C9530C7B39A75AEDF, ordinal: 0
2016-01-14 17:51:12,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:12,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 17:51:12,192 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5647330688B493C9530C7B39A75AEDF, mem on start (mb), free: 264, total: 276, max: 672
2016-01-14 17:51:12,194 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5647330688B493C9530C7B39A75AEDF, mem on close (mb), free: 264, total: 276, max: 672
2016-01-14 17:51:15,189 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-14 17:51:15,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.052
2016-01-14 17:51:15,201 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-14 17:51:15,206 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:15,206 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 17:51:15,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:51:15,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:15,224 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 17:51:15,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:15,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:15,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 17:51:15,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:15,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:15,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:15,234 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-14 17:51:15,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0030
2016-01-14 17:51:15,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:15,257 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:15,260 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:15,261 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:15,268 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1DFD93B5E1C4C84AE6DA73CB5496878, ordinal: 0
2016-01-14 17:51:15,268 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:15,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 17:51:15,269 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1DFD93B5E1C4C84AE6DA73CB5496878, mem on start (mb), free: 253, total: 276, max: 672
2016-01-14 17:51:15,271 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1DFD93B5E1C4C84AE6DA73CB5496878, mem on close (mb), free: 253, total: 276, max: 672
2016-01-14 17:51:18,261 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-14 17:51:18,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.030
2016-01-14 17:51:18,273 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-14 17:51:18,280 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:18,281 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 17:51:18,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:51:18,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:51:18,300 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 17:51:18,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2016-01-14 17:51:18,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:18,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 17:51:18,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] parallel execution of steps is enabled: false
2016-01-14 17:51:18,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executing total steps: 1
2016-01-14 17:51:18,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] allocating management threads: 1
2016-01-14 17:51:18,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 17:51:18,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local_0031
2016-01-14 17:51:18,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2016-01-14 17:51:18,332 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt
2016-01-14 17:51:18,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:51:18,335 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:51:18,340 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F747983C438046788220993C291399F8, ordinal: 0
2016-01-14 17:51:18,341 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/nums.20.txt"]
2016-01-14 17:51:18,341 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 17:51:18,341 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F747983C438046788220993C291399F8, mem on start (mb), free: 242, total: 276, max: 672
2016-01-14 17:51:18,345 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F747983C438046788220993C291399F8, mem on close (mb), free: 242, total: 276, max: 672
2016-01-14 17:51:21,336 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-14 17:51:21,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] completed in: 00:03.029
2016-01-14 17:51:21,348 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 17:51:21,352 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:51:21,353 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 17:51:21,361 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 17:51:21,361 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 17:51:21,361 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'