2016-01-14 20:49:35,355 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 20:49:35,370 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop
2016-01-14 20:49:35,801 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 20:49:36,005 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 20:49:36,069 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:36,070 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 20:49:36,171 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: F898EAF23D5C403F8AA4C65B5EE282EC
2016-01-14 20:49:36,298 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-01-14 20:49:36,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:36,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:36,443 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 20:49:36,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:36,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:36,444 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 20:49:36,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:36,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:36,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:36,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-14 20:49:36,492 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 20:49:36,541 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-01-14 20:49:36,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0001
2016-01-14 20:49:36,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:36,824 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:36,838 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:36,839 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:36,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B66CCC0F356A43279ECF06C8E9307426, ordinal: 0
2016-01-14 20:49:36,893 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:36,894 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-14 20:49:36,895 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B66CCC0F356A43279ECF06C8E9307426, mem on start (mb), free: 245, total: 281, max: 672
2016-01-14 20:49:36,905 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B66CCC0F356A43279ECF06C8E9307426, mem on close (mb), free: 245, total: 281, max: 672
2016-01-14 20:49:39,812 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-14 20:49:39,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.366
2016-01-14 20:49:39,856 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-14 20:49:39,875 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:39,876 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 20:49:39,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-14 20:49:39,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:39,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:39,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:39,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:39,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 20:49:39,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:39,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:39,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:39,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-14 20:49:40,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0002
2016-01-14 20:49:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:40,057 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:40,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:40,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:40,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA5FD1E4F1B24AF68F2E085A75E873FB, ordinal: 0
2016-01-14 20:49:40,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:40,077 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-14 20:49:40,077 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA5FD1E4F1B24AF68F2E085A75E873FB, mem on start (mb), free: 233, total: 281, max: 672
2016-01-14 20:49:40,080 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA5FD1E4F1B24AF68F2E085A75E873FB, mem on close (mb), free: 233, total: 281, max: 672
2016-01-14 20:49:43,069 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-14 20:49:43,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.099
2016-01-14 20:49:43,104 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-14 20:49:43,124 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:43,124 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 20:49:43,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2016-01-14 20:49:43,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:43,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:43,218 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:43,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:43,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 20:49:43,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:43,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:43,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:43,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-14 20:49:43,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0003
2016-01-14 20:49:43,312 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:43,317 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:43,322 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:43,323 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:43,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2EDB0544DB64A31AC1760FB5F467829, ordinal: 0
2016-01-14 20:49:43,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:43,334 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-14 20:49:43,334 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2EDB0544DB64A31AC1760FB5F467829, mem on start (mb), free: 221, total: 281, max: 672
2016-01-14 20:49:43,337 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2EDB0544DB64A31AC1760FB5F467829, mem on close (mb), free: 221, total: 281, max: 672
2016-01-14 20:49:46,320 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-14 20:49:46,321 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.102
2016-01-14 20:49:46,346 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-14 20:49:46,356 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:46,357 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 20:49:46,409 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-14 20:49:46,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:46,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:46,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:46,425 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:46,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 20:49:46,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:46,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:46,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:46,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-14 20:49:46,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0004
2016-01-14 20:49:46,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:46,475 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:46,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:46,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:46,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FA3E0EC1DD65401E85D8F26DE099C553, ordinal: 0
2016-01-14 20:49:46,490 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:46,490 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-14 20:49:46,490 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA3E0EC1DD65401E85D8F26DE099C553, mem on start (mb), free: 210, total: 281, max: 672
2016-01-14 20:49:46,493 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA3E0EC1DD65401E85D8F26DE099C553, mem on close (mb), free: 210, total: 281, max: 672
2016-01-14 20:49:49,484 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-14 20:49:49,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.059
2016-01-14 20:49:49,507 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-14 20:49:49,518 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:49,518 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 20:49:49,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-14 20:49:49,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:49,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:49,583 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:49,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:49,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 20:49:49,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:49,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:49,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:49,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-14 20:49:49,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0005
2016-01-14 20:49:49,628 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:49,635 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:49,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:49,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:49,657 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1E5598E8EE9463F9631E63E3DCBF210, ordinal: 0
2016-01-14 20:49:49,659 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:49,659 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-14 20:49:49,659 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1E5598E8EE9463F9631E63E3DCBF210, mem on start (mb), free: 198, total: 281, max: 672
2016-01-14 20:49:49,661 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1E5598E8EE9463F9631E63E3DCBF210, mem on close (mb), free: 198, total: 281, max: 672
2016-01-14 20:49:52,645 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-14 20:49:52,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.062
2016-01-14 20:49:52,667 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-14 20:49:52,677 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:52,677 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 20:49:52,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-14 20:49:52,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:52,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:52,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:52,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:52,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 20:49:52,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:52,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:52,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:52,744 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-14 20:49:52,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0006
2016-01-14 20:49:52,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:52,786 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:52,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:52,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:52,799 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F3F7317247D648529FD12E0001486548, ordinal: 0
2016-01-14 20:49:52,799 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:52,800 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-14 20:49:52,800 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3F7317247D648529FD12E0001486548, mem on start (mb), free: 186, total: 281, max: 672
2016-01-14 20:49:52,802 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3F7317247D648529FD12E0001486548, mem on close (mb), free: 186, total: 281, max: 672
2016-01-14 20:49:55,790 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-14 20:49:55,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.046
2016-01-14 20:49:55,813 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-14 20:49:55,821 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:55,821 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 20:49:55,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-01-14 20:49:55,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:49:55,840 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-14 20:49:55,847 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:55,847 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 20:49:55,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 20:49:55,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:55,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:55,894 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:55,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:55,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 20:49:55,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:55,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:55,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:55,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-14 20:49:55,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0007
2016-01-14 20:49:55,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:55,941 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:55,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:55,945 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:55,953 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B6F176FC253F4D7E807DB8F33E4E5D85, ordinal: 0
2016-01-14 20:49:55,954 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:55,954 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-14 20:49:55,954 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6F176FC253F4D7E807DB8F33E4E5D85, mem on start (mb), free: 172, total: 281, max: 672
2016-01-14 20:49:55,957 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6F176FC253F4D7E807DB8F33E4E5D85, mem on close (mb), free: 172, total: 281, max: 672
2016-01-14 20:49:58,953 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-14 20:49:58,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.058
2016-01-14 20:49:58,977 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-14 20:49:58,988 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:49:58,989 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 20:49:59,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 20:49:59,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:49:59,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:49:59,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:49:59,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:59,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 20:49:59,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:49:59,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:49:59,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:49:59,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-14 20:49:59,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0008
2016-01-14 20:49:59,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:49:59,077 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:49:59,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:49:59,081 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:49:59,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B804800BDC8C4A56957E3A64AD9B0ED7, ordinal: 0
2016-01-14 20:49:59,090 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:49:59,090 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-14 20:49:59,090 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B804800BDC8C4A56957E3A64AD9B0ED7, mem on start (mb), free: 160, total: 281, max: 672
2016-01-14 20:49:59,092 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B804800BDC8C4A56957E3A64AD9B0ED7, mem on close (mb), free: 160, total: 281, max: 672
2016-01-14 20:50:02,087 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-14 20:50:02,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.050
2016-01-14 20:50:02,132 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-14 20:50:02,138 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:02,139 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 20:50:02,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 20:50:02,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:02,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:02,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:02,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:02,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 20:50:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:02,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:02,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 20:50:02,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0009
2016-01-14 20:50:02,210 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:02,215 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:02,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:02,220 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:02,231 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DDD44722A5144BFDBD5B344F3B136859, ordinal: 0
2016-01-14 20:50:02,232 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:02,232 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-14 20:50:02,233 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDD44722A5144BFDBD5B344F3B136859, mem on start (mb), free: 261, total: 281, max: 672
2016-01-14 20:50:02,236 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDD44722A5144BFDBD5B344F3B136859, mem on close (mb), free: 261, total: 281, max: 672
2016-01-14 20:50:05,223 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-14 20:50:05,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.043
2016-01-14 20:50:05,237 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-14 20:50:05,243 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,243 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 20:50:05,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 20:50:05,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:05,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:05,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:05,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 20:50:05,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:05,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:05,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:05,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 20:50:05,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0010
2016-01-14 20:50:05,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:05,321 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:05,324 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:05,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:05,332 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A543527378714B22816CBE106C45CECE, ordinal: 0
2016-01-14 20:50:05,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-14 20:50:05,333 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A543527378714B22816CBE106C45CECE, mem on start (mb), free: 250, total: 281, max: 672
2016-01-14 20:50:05,334 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 20:50:05,337 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 20:50:05,338 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 20:50:05,338 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A543527378714B22816CBE106C45CECE, mem on close (mb), free: 250, total: 281, max: 672
2016-01-14 20:50:05,339 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 20:50:05,349 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0010 state at FAILED
2016-01-14 20:50:05,349 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:05,350 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:05,350 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:05,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:05,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-14 20:50:05,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:05,352 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-14 20:50:05,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.062
2016-01-14 20:50:05,353 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-14 20:50:05,358 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,359 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 20:50:05,372 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-01-14 20:50:05,372 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:05,373 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-14 20:50:05,378 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,379 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 20:50:05,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 20:50:05,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:05,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:05,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:05,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 20:50:05,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:05,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:05,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:05,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 20:50:05,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0011
2016-01-14 20:50:05,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:05,457 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:05,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:05,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:05,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DE47C29E53C34CF4AA7F25215D8E4EAF, ordinal: 0
2016-01-14 20:50:05,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,476 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-14 20:50:05,476 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE47C29E53C34CF4AA7F25215D8E4EAF, mem on start (mb), free: 241, total: 281, max: 672
2016-01-14 20:50:05,477 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 20:50:05,483 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 20:50:05,488 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 20:50:05,489 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE47C29E53C34CF4AA7F25215D8E4EAF, mem on close (mb), free: 241, total: 281, max: 672
2016-01-14 20:50:05,490 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 20:50:05,495 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0011 state at FAILED
2016-01-14 20:50:05,495 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:05,495 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:05,495 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:05,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-14 20:50:05,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:05,496 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-14 20:50:05,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.074
2016-01-14 20:50:05,497 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-14 20:50:05,506 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,506 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 20:50:05,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 20:50:05,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:05,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:05,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:05,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 20:50:05,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:05,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:05,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:05,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 20:50:05,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0012
2016-01-14 20:50:05,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:05,573 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:05,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:05,578 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:05,589 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D094EC4761504AEFBD9A666DDEEDD840, ordinal: 0
2016-01-14 20:50:05,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-14 20:50:05,590 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D094EC4761504AEFBD9A666DDEEDD840, mem on start (mb), free: 232, total: 281, max: 672
2016-01-14 20:50:05,591 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 20:50:05,593 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 20:50:05,594 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 20:50:05,601 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D094EC4761504AEFBD9A666DDEEDD840, mem on close (mb), free: 232, total: 281, max: 672
2016-01-14 20:50:05,602 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 20:50:05,611 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0012 state at FAILED
2016-01-14 20:50:05,611 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:05,612 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:05,612 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:05,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:05,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-14 20:50:05,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:05,614 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-14 20:50:05,614 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.069
2016-01-14 20:50:05,615 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-14 20:50:05,623 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,624 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 20:50:05,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-14 20:50:05,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:05,637 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-14 20:50:05,646 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:05,648 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 20:50:05,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 20:50:05,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:05,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:05,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:05,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 20:50:05,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:05,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:05,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:05,686 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-14 20:50:05,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0013
2016-01-14 20:50:05,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:05,713 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:05,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:05,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:05,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6D47B20F4744D5CA181D725CB017098, ordinal: 0
2016-01-14 20:50:05,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:05,724 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-14 20:50:05,724 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6D47B20F4744D5CA181D725CB017098, mem on start (mb), free: 223, total: 281, max: 672
2016-01-14 20:50:05,726 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6D47B20F4744D5CA181D725CB017098, mem on close (mb), free: 223, total: 281, max: 672
2016-01-14 20:50:08,723 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-14 20:50:08,724 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.039
2016-01-14 20:50:08,738 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-14 20:50:08,744 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:08,744 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 20:50:08,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-14 20:50:08,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:08,756 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-14 20:50:08,763 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:08,763 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 20:50:08,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 20:50:08,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:08,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:08,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:08,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:08,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 20:50:08,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:08,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:08,796 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:08,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-14 20:50:08,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0014
2016-01-14 20:50:08,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:08,839 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:08,842 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:08,843 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:08,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F9FD36ECF4A34AD89E7EF097797C4925, ordinal: 0
2016-01-14 20:50:08,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:08,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-14 20:50:08,851 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9FD36ECF4A34AD89E7EF097797C4925, mem on start (mb), free: 209, total: 281, max: 672
2016-01-14 20:50:08,853 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9FD36ECF4A34AD89E7EF097797C4925, mem on close (mb), free: 209, total: 281, max: 672
2016-01-14 20:50:11,843 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-14 20:50:11,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.048
2016-01-14 20:50:11,856 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-14 20:50:11,862 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:11,862 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 20:50:11,888 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 20:50:11,888 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:11,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:11,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:11,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:11,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 20:50:11,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:11,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:11,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:11,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-14 20:50:11,920 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0015
2016-01-14 20:50:11,921 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:11,924 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:11,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:11,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:11,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D947B3E746294855929E182E65CDF37A, ordinal: 0
2016-01-14 20:50:11,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:11,939 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-14 20:50:11,939 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D947B3E746294855929E182E65CDF37A, mem on start (mb), free: 197, total: 281, max: 672
2016-01-14 20:50:11,942 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D947B3E746294855929E182E65CDF37A, mem on close (mb), free: 197, total: 281, max: 672
2016-01-14 20:50:14,936 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-14 20:50:14,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.040
2016-01-14 20:50:14,950 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-14 20:50:14,956 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:14,957 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 20:50:14,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 20:50:14,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:14,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:14,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:14,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:14,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 20:50:14,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:14,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:14,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:14,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-14 20:50:15,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0016
2016-01-14 20:50:15,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:15,023 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:15,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:15,027 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:15,033 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EE858FC56904488B9625CF03D54E6C40, ordinal: 0
2016-01-14 20:50:15,034 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:15,034 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-14 20:50:15,034 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE858FC56904488B9625CF03D54E6C40, mem on start (mb), free: 186, total: 281, max: 672
2016-01-14 20:50:15,036 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE858FC56904488B9625CF03D54E6C40, mem on close (mb), free: 186, total: 281, max: 672
2016-01-14 20:50:18,026 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-14 20:50:18,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.036
2016-01-14 20:50:18,041 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-14 20:50:18,047 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:18,047 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 20:50:18,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 20:50:18,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:18,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:18,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:18,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:18,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 20:50:18,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:18,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:18,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:18,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-14 20:50:18,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0017
2016-01-14 20:50:18,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:18,138 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:18,142 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:18,142 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:18,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A88CCA38EA8E43298103276A67933C26, ordinal: 0
2016-01-14 20:50:18,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:18,153 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-14 20:50:18,153 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A88CCA38EA8E43298103276A67933C26, mem on start (mb), free: 177, total: 281, max: 672
2016-01-14 20:50:18,156 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A88CCA38EA8E43298103276A67933C26, mem on close (mb), free: 177, total: 281, max: 672
2016-01-14 20:50:21,147 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-14 20:50:21,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.053
2016-01-14 20:50:21,160 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-14 20:50:21,165 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:21,166 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 20:50:21,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 20:50:21,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:21,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:21,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:21,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:21,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 20:50:21,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:21,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:21,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:21,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-14 20:50:21,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0018
2016-01-14 20:50:21,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:21,225 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:21,227 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:21,227 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:21,233 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F40A4B4944424B88A7F68C211068726A, ordinal: 0
2016-01-14 20:50:21,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:21,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-14 20:50:21,234 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F40A4B4944424B88A7F68C211068726A, mem on start (mb), free: 166, total: 281, max: 672
2016-01-14 20:50:21,236 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F40A4B4944424B88A7F68C211068726A, mem on close (mb), free: 166, total: 281, max: 672
2016-01-14 20:50:24,229 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-14 20:50:24,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.033
2016-01-14 20:50:24,246 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-14 20:50:24,252 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:24,253 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 20:50:24,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-14 20:50:24,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:24,265 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-14 20:50:24,270 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:24,271 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 20:50:24,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 20:50:24,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:24,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:24,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:24,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:24,303 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 20:50:24,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:24,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:24,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:24,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-14 20:50:24,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0019
2016-01-14 20:50:24,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:24,330 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:24,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:24,333 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:24,340 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9734CCCBEE7483492D43F69419BCB54, ordinal: 0
2016-01-14 20:50:24,340 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:24,340 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-14 20:50:24,340 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9734CCCBEE7483492D43F69419BCB54, mem on start (mb), free: 155, total: 281, max: 672
2016-01-14 20:50:24,343 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9734CCCBEE7483492D43F69419BCB54, mem on close (mb), free: 155, total: 281, max: 672
2016-01-14 20:50:27,340 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-14 20:50:27,340 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.037
2016-01-14 20:50:27,353 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-14 20:50:27,358 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:27,358 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 20:50:27,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 20:50:27,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:27,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:27,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:27,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:27,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 20:50:27,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:27,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:27,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:27,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-14 20:50:27,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0020
2016-01-14 20:50:27,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:27,427 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:27,430 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:27,431 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:27,441 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C95DC59BB2A146E997C2F7E3041FAAF3, ordinal: 0
2016-01-14 20:50:27,442 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:27,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-14 20:50:27,444 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C95DC59BB2A146E997C2F7E3041FAAF3, mem on start (mb), free: 261, total: 281, max: 672
2016-01-14 20:50:27,447 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C95DC59BB2A146E997C2F7E3041FAAF3, mem on close (mb), free: 261, total: 281, max: 672
2016-01-14 20:50:30,430 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-14 20:50:30,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.040
2016-01-14 20:50:30,443 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-14 20:50:30,448 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:30,448 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 20:50:30,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 20:50:30,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:30,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:30,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:30,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 20:50:30,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:30,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:30,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:30,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 20:50:30,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0021
2016-01-14 20:50:30,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:30,509 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:30,512 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:30,512 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:30,520 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA9D2BE2C3244BEEA2BE4ACA5298AF5C, ordinal: 0
2016-01-14 20:50:30,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,522 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-14 20:50:30,522 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA9D2BE2C3244BEEA2BE4ACA5298AF5C, mem on start (mb), free: 251, total: 281, max: 672
2016-01-14 20:50:30,523 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 20:50:30,526 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 20:50:30,529 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 20:50:30,532 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA9D2BE2C3244BEEA2BE4ACA5298AF5C, mem on close (mb), free: 251, total: 281, max: 672
2016-01-14 20:50:30,533 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 20:50:30,540 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0021 state at FAILED
2016-01-14 20:50:30,540 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:30,540 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:30,540 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:30,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:30,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-14 20:50:30,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:30,541 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-14 20:50:30,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.056
2016-01-14 20:50:30,542 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-14 20:50:30,550 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:30,551 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 20:50:30,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 20:50:30,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:30,561 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-14 20:50:30,569 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:30,570 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 20:50:30,589 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 20:50:30,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:30,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:30,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:30,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 20:50:30,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:30,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:30,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:30,602 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 20:50:30,622 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0022
2016-01-14 20:50:30,622 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:30,627 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:30,631 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:30,631 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:30,640 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E5D2B83BB463432F94E8A12D18C31CD9, ordinal: 0
2016-01-14 20:50:30,641 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,642 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-14 20:50:30,643 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5D2B83BB463432F94E8A12D18C31CD9, mem on start (mb), free: 240, total: 281, max: 672
2016-01-14 20:50:30,643 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 20:50:30,647 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 20:50:30,650 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 20:50:30,653 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5D2B83BB463432F94E8A12D18C31CD9, mem on close (mb), free: 240, total: 281, max: 672
2016-01-14 20:50:30,654 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 20:50:30,656 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0022 state at FAILED
2016-01-14 20:50:30,657 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:30,657 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:30,657 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:30,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:30,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-14 20:50:30,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:30,659 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-14 20:50:30,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.059
2016-01-14 20:50:30,659 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-14 20:50:30,665 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:30,665 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 20:50:30,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 20:50:30,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:30,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:30,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:30,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 20:50:30,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:30,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:30,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:30,710 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 20:50:30,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0023
2016-01-14 20:50:30,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:30,740 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:30,742 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:30,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:30,749 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA572C874A4D4021856F4C2FA6F62F31, ordinal: 0
2016-01-14 20:50:30,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-14 20:50:30,750 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA572C874A4D4021856F4C2FA6F62F31, mem on start (mb), free: 233, total: 281, max: 672
2016-01-14 20:50:30,751 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 20:50:30,753 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 20:50:30,755 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 20:50:30,755 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA572C874A4D4021856F4C2FA6F62F31, mem on close (mb), free: 232, total: 281, max: 672
2016-01-14 20:50:30,756 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 20:50:30,758 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local_0023 state at FAILED
2016-01-14 20:50:30,758 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-14 20:50:30,758 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-14 20:50:30,758 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-14 20:50:30,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-14 20:50:30,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-14 20:50:30,759 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-14 20:50:30,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-14 20:50:30,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:00.052
2016-01-14 20:50:30,760 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-14 20:50:30,768 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:30,768 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 20:50:30,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 20:50:30,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:30,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:30,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:30,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 20:50:30,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:30,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:30,798 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:30,799 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-14 20:50:30,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0024
2016-01-14 20:50:30,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:30,820 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:30,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:30,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:30,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BEB6FC04CFCE4D34A7716BAFB8347E4D, ordinal: 0
2016-01-14 20:50:30,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:30,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-14 20:50:30,833 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEB6FC04CFCE4D34A7716BAFB8347E4D, mem on start (mb), free: 225, total: 281, max: 672
2016-01-14 20:50:30,835 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEB6FC04CFCE4D34A7716BAFB8347E4D, mem on close (mb), free: 225, total: 281, max: 672
2016-01-14 20:50:33,823 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-14 20:50:33,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.026
2016-01-14 20:50:33,836 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-14 20:50:33,841 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:33,841 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 20:50:33,849 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-14 20:50:33,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:33,850 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-14 20:50:33,855 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:33,856 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 20:50:33,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 20:50:33,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:33,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 20:50:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:33,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:33,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:33,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-14 20:50:33,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0025
2016-01-14 20:50:33,903 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:33,907 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:33,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:33,909 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:33,915 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D323EC82CF574E1180A3D31B028A29F2, ordinal: 0
2016-01-14 20:50:33,915 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:33,915 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-14 20:50:33,916 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D323EC82CF574E1180A3D31B028A29F2, mem on start (mb), free: 213, total: 281, max: 672
2016-01-14 20:50:33,918 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D323EC82CF574E1180A3D31B028A29F2, mem on close (mb), free: 213, total: 281, max: 672
2016-01-14 20:50:36,912 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-14 20:50:36,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.029
2016-01-14 20:50:36,925 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-14 20:50:36,931 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:36,931 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 20:50:36,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.005
2016-01-14 20:50:36,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:36,940 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-14 20:50:36,946 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:36,946 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 20:50:36,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 20:50:36,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:36,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:36,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:36,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:36,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 20:50:36,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:36,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:36,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:36,976 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-14 20:50:37,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0026
2016-01-14 20:50:37,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:37,007 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:37,012 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:37,012 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:37,020 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D76103150CE3433095F6D9ED3BAECCCA, ordinal: 0
2016-01-14 20:50:37,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:37,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-14 20:50:37,022 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D76103150CE3433095F6D9ED3BAECCCA, mem on start (mb), free: 198, total: 281, max: 672
2016-01-14 20:50:37,025 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D76103150CE3433095F6D9ED3BAECCCA, mem on close (mb), free: 198, total: 281, max: 672
2016-01-14 20:50:40,010 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-14 20:50:40,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.036
2016-01-14 20:50:40,022 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-14 20:50:40,027 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:40,027 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 20:50:40,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-01-14 20:50:40,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:40,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:40,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:40,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-14 20:50:40,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0027
2016-01-14 20:50:40,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:40,076 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:40,079 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:40,079 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:40,084 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BEC0B0BC5BD14F9CBB93CE1E8A0A3854, ordinal: 0
2016-01-14 20:50:40,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:40,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-14 20:50:40,085 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEC0B0BC5BD14F9CBB93CE1E8A0A3854, mem on start (mb), free: 187, total: 281, max: 672
2016-01-14 20:50:40,087 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BEC0B0BC5BD14F9CBB93CE1E8A0A3854, mem on close (mb), free: 187, total: 281, max: 672
2016-01-14 20:50:43,079 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-14 20:50:43,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.026
2016-01-14 20:50:43,093 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-14 20:50:43,098 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:43,099 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 20:50:43,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-01-14 20:50:43,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:43,116 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 20:50:43,122 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:43,123 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:43,123 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:43,124 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-14 20:50:43,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0028
2016-01-14 20:50:43,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:43,155 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:43,159 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:43,159 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:43,167 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E639CB0A97544131931CB32763A19114, ordinal: 0
2016-01-14 20:50:43,168 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:43,168 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-14 20:50:43,168 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E639CB0A97544131931CB32763A19114, mem on start (mb), free: 177, total: 281, max: 672
2016-01-14 20:50:43,172 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E639CB0A97544131931CB32763A19114, mem on close (mb), free: 177, total: 281, max: 672
2016-01-14 20:50:46,158 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-14 20:50:46,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.036
2016-01-14 20:50:46,170 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-14 20:50:46,176 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:46,176 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 20:50:46,192 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-01-14 20:50:46,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:46,193 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:46,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:46,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:46,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 20:50:46,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:46,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:46,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:46,201 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-14 20:50:46,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0029
2016-01-14 20:50:46,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:46,223 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:46,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:46,225 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:46,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DAB5FC159F9E4635A81C0C4672BEEB37, ordinal: 0
2016-01-14 20:50:46,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:46,231 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-14 20:50:46,231 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAB5FC159F9E4635A81C0C4672BEEB37, mem on start (mb), free: 167, total: 281, max: 672
2016-01-14 20:50:46,233 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAB5FC159F9E4635A81C0C4672BEEB37, mem on close (mb), free: 167, total: 281, max: 672
2016-01-14 20:50:49,232 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-14 20:50:49,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.033
2016-01-14 20:50:49,244 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-14 20:50:49,249 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:49,250 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 20:50:49,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 20:50:49,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:49,269 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:49,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:49,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:49,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 20:50:49,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:49,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:49,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:49,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-14 20:50:49,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0030
2016-01-14 20:50:49,304 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:49,307 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:49,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:49,312 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:49,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D6CEA10CDEED49DC82D8456918DE8C77, ordinal: 0
2016-01-14 20:50:49,318 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:49,318 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-14 20:50:49,318 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6CEA10CDEED49DC82D8456918DE8C77, mem on start (mb), free: 157, total: 281, max: 672
2016-01-14 20:50:49,321 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6CEA10CDEED49DC82D8456918DE8C77, mem on close (mb), free: 157, total: 281, max: 672
2016-01-14 20:50:52,310 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-14 20:50:52,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.035
2016-01-14 20:50:52,333 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-14 20:50:52,339 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:52,339 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 20:50:52,355 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-01-14 20:50:52,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 20:50:52,356 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 20:50:52,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-14 20:50:52,364 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:52,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 20:50:52,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] parallel execution of steps is enabled: false
2016-01-14 20:50:52,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executing total steps: 1
2016-01-14 20:50:52,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] allocating management threads: 1
2016-01-14 20:50:52,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 20:50:52,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local_0031
2016-01-14 20:50:52,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-14 20:50:52,388 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt
2016-01-14 20:50:52,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 20:50:52,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 20:50:52,396 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5DF6DDF6C7D43949D216B8C80DAD011, ordinal: 0
2016-01-14 20:50:52,397 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/classes/test/data/nums.20.txt"]
2016-01-14 20:50:52,397 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-14 20:50:52,398 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5DF6DDF6C7D43949D216B8C80DAD011, mem on start (mb), free: 259, total: 277, max: 672
2016-01-14 20:50:52,400 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5DF6DDF6C7D43949D216B8C80DAD011, mem on close (mb), free: 259, total: 277, max: 672
2016-01-14 20:50:55,392 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-14 20:50:55,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] completed in: 00:03.028
2016-01-14 20:50:55,405 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-14 20:50:55,409 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 20:50:55,410 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 20:50:55,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.011
2016-01-14 20:50:55,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 20:50:55,423 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-1.0.x/build/test/output//hadoop/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'