Class cascading.detail.EachEachPipeAssemblyPlatformTest

all > cascading.detail > EachEachPipeAssemblyPlatformTest
40

tests
0

failures
0

ignored
10.498s

duration
100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.575s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.396s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 2.282s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.328s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.297s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.060s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.030s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.262s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.268s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.032s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.346s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.284s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.267s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.033s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.201s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.227s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.208s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.254s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.263s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.237s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.308s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.025s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.254s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.027s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.229s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.252s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.235s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.229s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.030s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.202s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.192s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.192s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.216s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.268s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.238s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.237s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.238s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.022s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.228s passed

Standard output

2016-05-18 12:00:59,127 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 12:00:59,151 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-05-18 12:00:59,612 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-18 12:01:00,238 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 12:01:00,372 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 12:01:00,484 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:00,486 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:00,564 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 536701FA821140C59F8B67787D2E7602
2016-05-18 12:01:00,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.095
2016-05-18 12:01:00,747 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:00,747 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:00,896 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 12:01:00,898 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:00,899 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:00,900 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 12:01:00,900 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:00,902 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:00,902 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:00,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-18 12:01:01,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local593713368_0001
2016-05-18 12:01:01,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:01,680 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:01,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:01,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:01,710 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A593136C0D2B41B79D937315B3D68D4E, ordinal: 0
2016-05-18 12:01:01,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:01,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 12:01:01,749 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A593136C0D2B41B79D937315B3D68D4E, mem on start (mb), free: 261, total: 281, max: 672
2016-05-18 12:01:01,759 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A593136C0D2B41B79D937315B3D68D4E, mem on close (mb), free: 261, total: 281, max: 672
2016-05-18 12:01:01,823 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-18 12:01:01,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.924
2016-05-18 12:01:01,893 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-18 12:01:01,922 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:01,923 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:01,989 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2016-05-18 12:01:01,990 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:01,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:02,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:02,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:02,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 12:01:02,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:02,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:02,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:02,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-18 12:01:02,159 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1791769091_0002
2016-05-18 12:01:02,160 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:02,165 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:02,174 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:02,175 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:02,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DABA18B4044043CAAC879EB2964A0BC3, ordinal: 0
2016-05-18 12:01:02,187 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:02,187 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 12:01:02,187 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DABA18B4044043CAAC879EB2964A0BC3, mem on start (mb), free: 196, total: 281, max: 672
2016-05-18 12:01:02,191 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DABA18B4044043CAAC879EB2964A0BC3, mem on close (mb), free: 196, total: 281, max: 672
2016-05-18 12:01:02,215 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-18 12:01:02,215 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.206
2016-05-18 12:01:02,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-18 12:01:02,311 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:02,312 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:02,360 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-18 12:01:02,362 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:02,362 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:02,377 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:02,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:02,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 12:01:02,378 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:02,379 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:02,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:02,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-18 12:01:02,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1856097819_0003
2016-05-18 12:01:02,736 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:02,751 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:02,763 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:02,763 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:02,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED90D555F614432DBD5D6C39AAC25949, ordinal: 0
2016-05-18 12:01:02,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:02,776 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 12:01:02,776 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED90D555F614432DBD5D6C39AAC25949, mem on start (mb), free: 365, total: 397, max: 672
2016-05-18 12:01:02,779 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED90D555F614432DBD5D6C39AAC25949, mem on close (mb), free: 365, total: 397, max: 672
2016-05-18 12:01:02,803 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-18 12:01:02,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.425
2016-05-18 12:01:02,865 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-18 12:01:02,881 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:02,881 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:02,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 12:01:02,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:02,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:02,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:02,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:02,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 12:01:02,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:02,936 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:02,936 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:02,937 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-18 12:01:03,058 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local266402356_0004
2016-05-18 12:01:03,059 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:03,065 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:03,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:03,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:03,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D65D28604DB146608EF6588B0667FCD6, ordinal: 0
2016-05-18 12:01:03,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 12:01:03,083 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D65D28604DB146608EF6588B0667FCD6, mem on start (mb), free: 291, total: 397, max: 672
2016-05-18 12:01:03,086 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D65D28604DB146608EF6588B0667FCD6, mem on close (mb), free: 291, total: 397, max: 672
2016-05-18 12:01:03,106 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-18 12:01:03,107 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.172
2016-05-18 12:01:03,162 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-18 12:01:03,178 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:03,179 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 12:01:03,216 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:03,216 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:03,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:03,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,228 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 12:01:03,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:03,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:03,229 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:03,231 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-18 12:01:03,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1807003331_0005
2016-05-18 12:01:03,371 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:03,377 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:03,387 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:03,388 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:03,401 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5E0FD82CA284B3DB0EAADFB83475947, ordinal: 0
2016-05-18 12:01:03,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 12:01:03,402 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E0FD82CA284B3DB0EAADFB83475947, mem on start (mb), free: 218, total: 397, max: 672
2016-05-18 12:01:03,406 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5E0FD82CA284B3DB0EAADFB83475947, mem on close (mb), free: 218, total: 397, max: 672
2016-05-18 12:01:03,428 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-18 12:01:03,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.199
2016-05-18 12:01:03,490 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-18 12:01:03,510 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:03,511 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:03,547 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 12:01:03,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:03,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:03,560 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:03,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 12:01:03,561 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:03,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:03,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:03,563 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-18 12:01:03,730 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local2010082247_0006
2016-05-18 12:01:03,730 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:03,742 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:03,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:03,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:03,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D22A5CE7314C4A11B565219223073DD6, ordinal: 0
2016-05-18 12:01:03,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 12:01:03,762 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D22A5CE7314C4A11B565219223073DD6, mem on start (mb), free: 377, total: 397, max: 672
2016-05-18 12:01:03,765 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D22A5CE7314C4A11B565219223073DD6, mem on close (mb), free: 377, total: 397, max: 672
2016-05-18 12:01:03,787 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-18 12:01:03,788 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.227
2016-05-18 12:01:03,836 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-18 12:01:03,851 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:03,851 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:03,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-05-18 12:01:03,868 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:03,869 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-18 12:01:03,883 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:03,883 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:03,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 12:01:03,916 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:03,916 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:03,927 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:03,927 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:03,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 12:01:03,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:03,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:03,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:03,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-18 12:01:04,041 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1909621408_0007
2016-05-18 12:01:04,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:04,047 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:04,055 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:04,055 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:04,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DB4CA4D0EE7C4589AB260B059FBF0BA4, ordinal: 0
2016-05-18 12:01:04,063 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 12:01:04,064 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB4CA4D0EE7C4589AB260B059FBF0BA4, mem on start (mb), free: 294, total: 397, max: 672
2016-05-18 12:01:04,067 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DB4CA4D0EE7C4589AB260B059FBF0BA4, mem on close (mb), free: 294, total: 397, max: 672
2016-05-18 12:01:04,087 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-18 12:01:04,088 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.160
2016-05-18 12:01:04,137 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-18 12:01:04,152 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:04,152 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:04,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 12:01:04,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:04,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:04,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:04,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-18 12:01:04,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local894875573_0008
2016-05-18 12:01:04,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:04,313 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:04,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:04,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:04,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DE4C5BD5BB4E4471B343ECF4DA714092, ordinal: 0
2016-05-18 12:01:04,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,330 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 12:01:04,330 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE4C5BD5BB4E4471B343ECF4DA714092, mem on start (mb), free: 218, total: 397, max: 672
2016-05-18 12:01:04,332 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE4C5BD5BB4E4471B343ECF4DA714092, mem on close (mb), free: 218, total: 397, max: 672
2016-05-18 12:01:04,352 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-18 12:01:04,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.156
2016-05-18 12:01:04,405 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-18 12:01:04,421 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:04,422 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:04,461 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-18 12:01:04,462 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:04,462 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:04,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:04,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 12:01:04,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:04,472 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:04,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:04,473 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 12:01:04,599 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1862791271_0009
2016-05-18 12:01:04,600 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:04,604 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:04,613 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:04,613 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:04,625 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DF06B810555141CC80D8809A0EF809D5, ordinal: 0
2016-05-18 12:01:04,626 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,626 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 12:01:04,626 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF06B810555141CC80D8809A0EF809D5, mem on start (mb), free: 367, total: 391, max: 672
2016-05-18 12:01:04,630 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF06B810555141CC80D8809A0EF809D5, mem on close (mb), free: 367, total: 391, max: 672
2016-05-18 12:01:04,643 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-18 12:01:04,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.171
2016-05-18 12:01:04,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 12:01:04,704 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:04,705 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:04,734 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 12:01:04,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:04,735 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:04,748 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:04,749 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,749 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 12:01:04,750 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:04,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:04,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:04,751 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 12:01:04,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local613965892_0010
2016-05-18 12:01:04,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:04,861 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:04,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:04,869 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:04,877 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B4AC3643D55E4600AAA9E8F4DFA8FFAB, ordinal: 0
2016-05-18 12:01:04,877 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,878 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 12:01:04,878 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4AC3643D55E4600AAA9E8F4DFA8FFAB, mem on start (mb), free: 289, total: 391, max: 672
2016-05-18 12:01:04,879 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:04,882 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:04,882 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:04,883 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4AC3643D55E4600AAA9E8F4DFA8FFAB, mem on close (mb), free: 288, total: 391, max: 672
2016-05-18 12:01:04,885 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local613965892_0010
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:04,887 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local613965892_0010 state at FAILED
2016-05-18 12:01:04,888 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:04,889 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:04,889 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:04,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:04,889 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 12:01:04,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:04,890 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-18 12:01:04,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.142
2016-05-18 12:01:04,891 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-18 12:01:04,905 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:04,905 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:04,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-05-18 12:01:04,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:04,923 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-18 12:01:04,940 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:04,941 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:04,966 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 12:01:04,967 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:04,967 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:04,976 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:04,977 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:04,977 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 12:01:04,978 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:04,978 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:04,978 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:04,979 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 12:01:05,088 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local678214919_0011
2016-05-18 12:01:05,088 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:05,093 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:05,101 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:05,101 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:05,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C5AD9967B943449CA9F5F440E7F2F910, ordinal: 0
2016-05-18 12:01:05,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 12:01:05,109 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C5AD9967B943449CA9F5F440E7F2F910, mem on start (mb), free: 220, total: 391, max: 672
2016-05-18 12:01:05,110 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,114 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,119 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,122 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C5AD9967B943449CA9F5F440E7F2F910, mem on close (mb), free: 220, total: 391, max: 672
2016-05-18 12:01:05,124 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local678214919_0011
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,129 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local678214919_0011 state at FAILED
2016-05-18 12:01:05,129 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:05,130 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:05,130 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:05,130 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:05,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 12:01:05,131 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:05,132 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-18 12:01:05,132 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.155
2016-05-18 12:01:05,132 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-18 12:01:05,145 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,145 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:05,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-18 12:01:05,189 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:05,190 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:05,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:05,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 12:01:05,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:05,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:05,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:05,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 12:01:05,320 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local953562405_0012
2016-05-18 12:01:05,324 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:05,329 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:05,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:05,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:05,348 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DAC8BCACF60D4FBC8DF12703BA451605, ordinal: 0
2016-05-18 12:01:05,349 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,349 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 12:01:05,349 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAC8BCACF60D4FBC8DF12703BA451605, mem on start (mb), free: 158, total: 391, max: 672
2016-05-18 12:01:05,350 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,351 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,352 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,353 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DAC8BCACF60D4FBC8DF12703BA451605, mem on close (mb), free: 158, total: 391, max: 672
2016-05-18 12:01:05,355 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local953562405_0012
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:05,355 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local953562405_0012 state at FAILED
2016-05-18 12:01:05,357 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:05,357 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:05,357 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:05,358 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:05,358 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 12:01:05,358 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:05,359 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-18 12:01:05,359 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.159
2016-05-18 12:01:05,360 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-18 12:01:05,379 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,379 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:05,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.017
2016-05-18 12:01:05,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:05,420 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-18 12:01:05,440 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:05,467 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 12:01:05,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:05,468 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:05,476 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:05,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 12:01:05,477 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:05,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:05,478 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:05,479 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-18 12:01:05,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local750128874_0013
2016-05-18 12:01:05,583 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:05,587 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:05,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:05,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:05,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B58547BDF9134E16BEC65D60FE79277D, ordinal: 0
2016-05-18 12:01:05,604 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,604 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 12:01:05,604 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B58547BDF9134E16BEC65D60FE79277D, mem on start (mb), free: 314, total: 394, max: 672
2016-05-18 12:01:05,607 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B58547BDF9134E16BEC65D60FE79277D, mem on close (mb), free: 314, total: 394, max: 672
2016-05-18 12:01:05,626 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-18 12:01:05,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.150
2016-05-18 12:01:05,682 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-18 12:01:05,696 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,697 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:05,713 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-05-18 12:01:05,713 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:05,713 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-18 12:01:05,731 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,732 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:05,767 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 12:01:05,768 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:05,768 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:05,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:05,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 12:01:05,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:05,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:05,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:05,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-18 12:01:05,882 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1790790749_0014
2016-05-18 12:01:05,882 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:05,889 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:05,898 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:05,898 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:05,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B060FC3239164369BF445199F349DBEF, ordinal: 0
2016-05-18 12:01:05,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:05,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 12:01:05,907 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B060FC3239164369BF445199F349DBEF, mem on start (mb), free: 222, total: 394, max: 672
2016-05-18 12:01:05,909 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B060FC3239164369BF445199F349DBEF, mem on close (mb), free: 222, total: 394, max: 672
2016-05-18 12:01:05,928 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-18 12:01:05,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.150
2016-05-18 12:01:05,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-18 12:01:05,990 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:05,991 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:06,016 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 12:01:06,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:06,017 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:06,027 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 12:01:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:06,029 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-18 12:01:06,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local151000027_0015
2016-05-18 12:01:06,139 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:06,145 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:06,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:06,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:06,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE546086BAB743D7A07895436606537E, ordinal: 0
2016-05-18 12:01:06,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 12:01:06,161 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE546086BAB743D7A07895436606537E, mem on start (mb), free: 363, total: 393, max: 672
2016-05-18 12:01:06,164 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE546086BAB743D7A07895436606537E, mem on close (mb), free: 363, total: 393, max: 672
2016-05-18 12:01:06,184 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-18 12:01:06,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.157
2016-05-18 12:01:06,231 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-18 12:01:06,244 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:06,245 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:06,273 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 12:01:06,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:06,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:06,290 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:06,290 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,290 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 12:01:06,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:06,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:06,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:06,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-18 12:01:06,440 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1788606416_0016
2016-05-18 12:01:06,441 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:06,448 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:06,456 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:06,456 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:06,463 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F10DA5927C4F4079B7F107A557C256C7, ordinal: 0
2016-05-18 12:01:06,463 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 12:01:06,464 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F10DA5927C4F4079B7F107A557C256C7, mem on start (mb), free: 287, total: 393, max: 672
2016-05-18 12:01:06,467 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F10DA5927C4F4079B7F107A557C256C7, mem on close (mb), free: 287, total: 393, max: 672
2016-05-18 12:01:06,485 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-18 12:01:06,486 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.195
2016-05-18 12:01:06,538 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-18 12:01:06,552 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:06,553 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:06,577 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 12:01:06,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:06,578 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:06,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:06,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-18 12:01:06,686 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local92309104_0017
2016-05-18 12:01:06,687 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:06,691 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:06,698 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:06,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:06,706 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDF62961F45F44E7833F1F07042E09F2, ordinal: 0
2016-05-18 12:01:06,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 12:01:06,707 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDF62961F45F44E7833F1F07042E09F2, mem on start (mb), free: 210, total: 393, max: 672
2016-05-18 12:01:06,710 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDF62961F45F44E7833F1F07042E09F2, mem on close (mb), free: 210, total: 393, max: 672
2016-05-18 12:01:06,731 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-18 12:01:06,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.143
2016-05-18 12:01:06,776 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-18 12:01:06,788 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:06,789 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:06,810 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 12:01:06,811 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:06,812 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:06,821 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:06,821 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,821 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 12:01:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-18 12:01:06,932 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1976637374_0018
2016-05-18 12:01:06,933 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:06,939 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:06,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:06,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:06,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA6621D13D8644A089BE1DD035122491, ordinal: 0
2016-05-18 12:01:06,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:06,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 12:01:06,957 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA6621D13D8644A089BE1DD035122491, mem on start (mb), free: 358, total: 394, max: 672
2016-05-18 12:01:06,961 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA6621D13D8644A089BE1DD035122491, mem on close (mb), free: 358, total: 394, max: 672
2016-05-18 12:01:06,976 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-18 12:01:06,977 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.155
2016-05-18 12:01:07,027 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-18 12:01:07,041 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,041 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,053 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-05-18 12:01:07,053 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:07,054 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-18 12:01:07,066 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,066 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 12:01:07,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:07,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:07,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:07,095 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-18 12:01:07,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1901366613_0019
2016-05-18 12:01:07,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:07,198 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:07,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:07,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:07,213 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E0E4099949A34505A9055C82107527FC, ordinal: 0
2016-05-18 12:01:07,214 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,214 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 12:01:07,214 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0E4099949A34505A9055C82107527FC, mem on start (mb), free: 275, total: 394, max: 672
2016-05-18 12:01:07,217 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0E4099949A34505A9055C82107527FC, mem on close (mb), free: 275, total: 394, max: 672
2016-05-18 12:01:07,237 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-18 12:01:07,238 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.143
2016-05-18 12:01:07,283 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-18 12:01:07,296 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,296 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 12:01:07,316 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:07,317 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:07,325 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:07,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 12:01:07,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:07,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:07,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:07,328 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-18 12:01:07,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local377037833_0020
2016-05-18 12:01:07,429 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:07,433 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:07,441 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:07,441 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:07,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A825C217EA70405088EE78AB19965B7D, ordinal: 0
2016-05-18 12:01:07,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 12:01:07,448 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A825C217EA70405088EE78AB19965B7D, mem on start (mb), free: 198, total: 394, max: 672
2016-05-18 12:01:07,451 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A825C217EA70405088EE78AB19965B7D, mem on close (mb), free: 198, total: 394, max: 672
2016-05-18 12:01:07,474 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-18 12:01:07,474 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.148
2016-05-18 12:01:07,518 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-18 12:01:07,535 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,536 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,555 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 12:01:07,555 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:07,556 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:07,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:07,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 12:01:07,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:07,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:07,565 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:07,566 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 12:01:07,675 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local198571361_0021
2016-05-18 12:01:07,675 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:07,680 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:07,688 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:07,688 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:07,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F3CB41FE4F9B4C6F84F6FDA214525DB9, ordinal: 0
2016-05-18 12:01:07,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,700 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 12:01:07,700 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3CB41FE4F9B4C6F84F6FDA214525DB9, mem on start (mb), free: 348, total: 394, max: 672
2016-05-18 12:01:07,700 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,703 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,706 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,709 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F3CB41FE4F9B4C6F84F6FDA214525DB9, mem on close (mb), free: 348, total: 394, max: 672
2016-05-18 12:01:07,710 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local198571361_0021
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,717 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local198571361_0021 state at FAILED
2016-05-18 12:01:07,718 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:07,718 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:07,718 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:07,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:07,719 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 12:01:07,720 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:07,720 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-18 12:01:07,721 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.156
2016-05-18 12:01:07,721 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-18 12:01:07,738 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,738 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,752 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2016-05-18 12:01:07,752 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:07,752 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-18 12:01:07,765 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,765 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,788 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 12:01:07,789 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:07,789 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:07,797 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:07,798 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,798 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 12:01:07,798 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:07,799 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:07,799 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:07,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 12:01:07,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local822293080_0022
2016-05-18 12:01:07,904 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:07,908 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:07,916 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:07,916 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:07,921 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F9AD6935F1D742DB9700E847AF459FA0, ordinal: 0
2016-05-18 12:01:07,922 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,922 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 12:01:07,923 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9AD6935F1D742DB9700E847AF459FA0, mem on start (mb), free: 279, total: 394, max: 672
2016-05-18 12:01:07,923 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,924 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,925 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,925 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9AD6935F1D742DB9700E847AF459FA0, mem on close (mb), free: 279, total: 394, max: 672
2016-05-18 12:01:07,929 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local822293080_0022
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:07,938 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local822293080_0022 state at FAILED
2016-05-18 12:01:07,938 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:07,938 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:07,938 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:07,939 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:07,942 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 12:01:07,943 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:07,943 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-18 12:01:07,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.146
2016-05-18 12:01:07,944 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-18 12:01:07,959 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:07,960 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:07,984 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 12:01:07,985 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:07,985 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:07,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:07,994 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:07,994 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 12:01:07,994 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:07,995 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:07,995 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:07,998 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 12:01:08,098 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1339230665_0023
2016-05-18 12:01:08,099 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:08,104 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:08,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:08,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:08,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADBBF1FF81184662AF90F83F7B8734EC, ordinal: 0
2016-05-18 12:01:08,120 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 12:01:08,121 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADBBF1FF81184662AF90F83F7B8734EC, mem on start (mb), free: 218, total: 394, max: 672
2016-05-18 12:01:08,121 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:08,123 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:08,123 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:08,127 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADBBF1FF81184662AF90F83F7B8734EC, mem on close (mb), free: 218, total: 394, max: 672
2016-05-18 12:01:08,128 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1339230665_0023
java.lang.Exception: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.pipe.OperatorException: [each.each][cascading.detail.EachAssemblyFactory.createAssembly(EachAssemblyFactory.java:33)] operator Each failed executing operation
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:108)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:95)
	at cascading.TestFunction.operate(TestFunction.java:104)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: current entry and given tuple must be same length
	at cascading.tuple.TupleEntry.setCanonicalTuple(TupleEntry.java:405)
	at cascading.TestFunction.operate(TestFunction.java:101)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	... 18 more
2016-05-18 12:01:08,133 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] hadoop job job_local1339230665_0023 state at FAILED
2016-05-18 12:01:08,133 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] failure info: NA
2016-05-18 12:01:08,133 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events identify failed tasks
2016-05-18 12:01:08,133 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [each.each] task completion events count: 0
2016-05-18 12:01:08,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping all jobs
2016-05-18 12:01:08,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 12:01:08,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] stopped all jobs
2016-05-18 12:01:08,135 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-18 12:01:08,135 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.141
2016-05-18 12:01:08,136 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-18 12:01:08,148 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,148 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 12:01:08,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:08,169 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:08,176 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:08,177 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,177 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 12:01:08,177 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:08,177 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:08,177 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:08,178 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-18 12:01:08,275 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local547296341_0024
2016-05-18 12:01:08,275 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:08,280 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:08,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:08,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:08,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3E06485F4B242D4B07CDF571BCB485E, ordinal: 0
2016-05-18 12:01:08,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,296 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 12:01:08,296 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E06485F4B242D4B07CDF571BCB485E, mem on start (mb), free: 156, total: 394, max: 672
2016-05-18 12:01:08,300 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E06485F4B242D4B07CDF571BCB485E, mem on close (mb), free: 156, total: 394, max: 672
2016-05-18 12:01:08,333 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-18 12:01:08,334 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.157
2016-05-18 12:01:08,390 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-18 12:01:08,405 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,405 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,415 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 12:01:08,415 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:08,416 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-18 12:01:08,428 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,428 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,447 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 12:01:08,447 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:08,447 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:08,453 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:08,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 12:01:08,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:08,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:08,454 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:08,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-18 12:01:08,557 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local660365012_0025
2016-05-18 12:01:08,557 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:08,561 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:08,570 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:08,570 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:08,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E51984EC43FE4EACB80088E8C799E653, ordinal: 0
2016-05-18 12:01:08,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 12:01:08,577 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E51984EC43FE4EACB80088E8C799E653, mem on start (mb), free: 286, total: 376, max: 672
2016-05-18 12:01:08,580 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E51984EC43FE4EACB80088E8C799E653, mem on close (mb), free: 285, total: 376, max: 672
2016-05-18 12:01:08,601 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-18 12:01:08,602 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.148
2016-05-18 12:01:08,645 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-18 12:01:08,661 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,661 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,672 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 12:01:08,672 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:08,672 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-18 12:01:08,686 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,687 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 12:01:08,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:08,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:08,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:08,714 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 12:01:08,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:08,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:08,715 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:08,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-18 12:01:08,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local515543732_0026
2016-05-18 12:01:08,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:08,821 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:08,829 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:08,829 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:08,834 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8C4E11051F2465AB8C0764400BFBAAE, ordinal: 0
2016-05-18 12:01:08,834 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,835 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 12:01:08,835 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8C4E11051F2465AB8C0764400BFBAAE, mem on start (mb), free: 211, total: 376, max: 672
2016-05-18 12:01:08,840 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8C4E11051F2465AB8C0764400BFBAAE, mem on close (mb), free: 210, total: 376, max: 672
2016-05-18 12:01:08,862 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-18 12:01:08,862 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.147
2016-05-18 12:01:08,911 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-18 12:01:08,924 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:08,924 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:08,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 12:01:08,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:08,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:08,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:08,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:08,952 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 12:01:08,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:08,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:08,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:08,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-18 12:01:09,081 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local257962562_0027
2016-05-18 12:01:09,082 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:09,085 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:09,102 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:09,103 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:09,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCF57D3557A7441BA69EE0D0B52AB6C0, ordinal: 0
2016-05-18 12:01:09,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 12:01:09,109 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF57D3557A7441BA69EE0D0B52AB6C0, mem on start (mb), free: 350, total: 368, max: 672
2016-05-18 12:01:09,111 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCF57D3557A7441BA69EE0D0B52AB6C0, mem on close (mb), free: 350, total: 368, max: 672
2016-05-18 12:01:09,127 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-18 12:01:09,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.175
2016-05-18 12:01:09,179 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-18 12:01:09,192 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:09,192 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:09,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 12:01:09,210 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:09,211 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:09,218 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:09,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 12:01:09,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:09,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:09,219 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:09,220 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-18 12:01:09,317 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local1428972349_0028
2016-05-18 12:01:09,317 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:09,321 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:09,328 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:09,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:09,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ACD4493CAB0143EEBBEA220EDF5D317F, ordinal: 0
2016-05-18 12:01:09,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 12:01:09,335 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACD4493CAB0143EEBBEA220EDF5D317F, mem on start (mb), free: 284, total: 368, max: 672
2016-05-18 12:01:09,337 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ACD4493CAB0143EEBBEA220EDF5D317F, mem on close (mb), free: 284, total: 368, max: 672
2016-05-18 12:01:09,350 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-18 12:01:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.132
2016-05-18 12:01:09,394 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-18 12:01:09,408 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:09,408 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:09,432 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 12:01:09,433 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:09,433 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:09,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:09,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,443 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 12:01:09,443 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:09,443 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:09,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:09,445 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-18 12:01:09,551 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local104274704_0029
2016-05-18 12:01:09,551 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:09,555 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:09,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:09,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:09,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BD398F3076434B3F997280416FBBC003, ordinal: 0
2016-05-18 12:01:09,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 12:01:09,569 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD398F3076434B3F997280416FBBC003, mem on start (mb), free: 220, total: 368, max: 672
2016-05-18 12:01:09,571 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BD398F3076434B3F997280416FBBC003, mem on close (mb), free: 220, total: 368, max: 672
2016-05-18 12:01:09,584 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-18 12:01:09,585 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.142
2016-05-18 12:01:09,632 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-18 12:01:09,644 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:09,645 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:09,661 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 12:01:09,661 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:09,662 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:09,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:09,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 12:01:09,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:09,670 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:09,671 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:09,673 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-18 12:01:09,769 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local207635563_0030
2016-05-18 12:01:09,770 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:09,774 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:09,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:09,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:09,788 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B59B46E92AD24DB4B0B35C7D89CDCF6E, ordinal: 0
2016-05-18 12:01:09,788 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 12:01:09,789 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B59B46E92AD24DB4B0B35C7D89CDCF6E, mem on start (mb), free: 156, total: 368, max: 672
2016-05-18 12:01:09,792 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B59B46E92AD24DB4B0B35C7D89CDCF6E, mem on close (mb), free: 156, total: 368, max: 672
2016-05-18 12:01:09,814 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-18 12:01:09,815 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.144
2016-05-18 12:01:09,870 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-18 12:01:09,883 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:09,883 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:09,899 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 12:01:09,900 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 12:01:09,900 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 12:01:09,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting
2016-05-18 12:01:09,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:09,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 12:01:09,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  parallel execution of steps is enabled: false
2016-05-18 12:01:09,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  executing total steps: 1
2016-05-18 12:01:09,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  allocating management threads: 1
2016-05-18 12:01:09,910 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 12:01:10,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] submitted hadoop job: job_local797909114_0031
2016-05-18 12:01:10,011 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] tracking url: http://localhost:8080/
2016-05-18 12:01:10,015 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt
2016-05-18 12:01:10,022 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 12:01:10,023 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 12:01:10,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EAEC0A01D5374DB0B9D6DBBAFFBBC3F6, ordinal: 0
2016-05-18 12:01:10,029 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/classes/test/data/nums.20.txt"]
2016-05-18 12:01:10,029 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 12:01:10,029 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAEC0A01D5374DB0B9D6DBBAFFBBC3F6, mem on start (mb), free: 288, total: 359, max: 672
2016-05-18 12:01:10,032 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAEC0A01D5374DB0B9D6DBBAFFBBC3F6, mem on close (mb), free: 288, total: 359, max: 672
2016-05-18 12:01:10,054 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-18 12:01:10,055 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each]  completed in: 00:00.147
2016-05-18 12:01:10,098 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 12:01:10,111 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 12:01:10,111 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-18 12:01:10,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 12:01:10,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 12:01:10,120 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.7.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'