Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

0

ignored

10.322s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.577s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.390s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 2.458s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.335s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.354s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.027s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.040s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.231s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.264s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.033s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.274s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.241s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.320s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.031s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.192s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.201s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.227s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.241s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.243s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.232s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.287s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.025s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.216s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.022s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.199s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.030s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.254s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.226s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.207s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.034s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.195s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.169s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.185s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.199s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.223s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.236s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.263s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.209s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.025s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.207s passed

Standard output

2016-05-18 08:51:47,959 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 08:51:47,980 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.detail.EveryEveryPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-05-18 08:51:48,451 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-18 08:51:49,154 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 08:51:49,363 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-18 08:51:49,477 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:49,480 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 08:51:49,590 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: C945BB1EBC314ED6A2D364ACFF11C0D2
2016-05-18 08:51:49,741 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2016-05-18 08:51:49,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:49,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:49,916 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 08:51:49,918 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:49,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:49,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 08:51:49,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:49,920 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:49,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:49,921 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-05-18 08:51:50,593 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local596829415_0001
2016-05-18 08:51:50,593 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:50,686 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:50,707 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:50,708 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:50,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED96640690544DAEADFD05F0F717D837, ordinal: 0
2016-05-18 08:51:50,757 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:50,758 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-05-18 08:51:50,759 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED96640690544DAEADFD05F0F717D837, mem on start (mb), free: 158, total: 223, max: 672
2016-05-18 08:51:50,770 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED96640690544DAEADFD05F0F717D837, mem on close (mb), free: 158, total: 223, max: 672
2016-05-18 08:51:50,843 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-05-18 08:51:50,844 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.924
2016-05-18 08:51:50,907 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-05-18 08:51:50,936 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:50,936 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 08:51:51,002 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-18 08:51:51,003 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:51,003 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:51,020 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:51,020 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:51,020 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 08:51:51,021 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:51,021 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:51,021 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:51,022 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-05-18 08:51:51,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1922939005_0002
2016-05-18 08:51:51,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:51,189 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:51,195 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:51,196 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:51,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B433B58F7D394DDDB60D4A0E82385BA6, ordinal: 0
2016-05-18 08:51:51,207 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:51,208 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-05-18 08:51:51,208 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B433B58F7D394DDDB60D4A0E82385BA6, mem on start (mb), free: 216, total: 281, max: 672
2016-05-18 08:51:51,212 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B433B58F7D394DDDB60D4A0E82385BA6, mem on close (mb), free: 216, total: 281, max: 672
2016-05-18 08:51:51,230 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-05-18 08:51:51,231 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.210
2016-05-18 08:51:51,299 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-05-18 08:51:51,322 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:51,323 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 08:51:51,370 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 08:51:51,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:51,372 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:51,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:51,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:51,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 08:51:51,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:51,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:51,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:51,391 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-05-18 08:51:51,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local464539502_0003
2016-05-18 08:51:51,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:51,726 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:51,734 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:51,734 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:51,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8A100DDB3C949EB9A9C0E4C140861B6, ordinal: 0
2016-05-18 08:51:51,750 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:51,750 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-05-18 08:51:51,750 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8A100DDB3C949EB9A9C0E4C140861B6, mem on start (mb), free: 161, total: 281, max: 672
2016-05-18 08:51:51,754 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8A100DDB3C949EB9A9C0E4C140861B6, mem on close (mb), free: 161, total: 281, max: 672
2016-05-18 08:51:51,775 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-05-18 08:51:51,776 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.387
2016-05-18 08:51:51,875 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-05-18 08:51:51,896 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:51,897 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 08:51:51,940 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 08:51:51,941 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:51,942 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:51,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:51,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:51,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 08:51:51,958 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:51,958 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:51,959 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:51,960 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-05-18 08:51:52,102 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local897965685_0004
2016-05-18 08:51:52,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:52,112 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:52,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:52,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:52,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A488090945774E5EA6885D835AF0A5D4, ordinal: 0
2016-05-18 08:51:52,135 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,135 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-05-18 08:51:52,136 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A488090945774E5EA6885D835AF0A5D4, mem on start (mb), free: 222, total: 281, max: 672
2016-05-18 08:51:52,140 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A488090945774E5EA6885D835AF0A5D4, mem on close (mb), free: 222, total: 281, max: 672
2016-05-18 08:51:52,164 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-05-18 08:51:52,165 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.209
2016-05-18 08:51:52,230 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-05-18 08:51:52,245 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:52,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 08:51:52,283 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 08:51:52,285 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:52,286 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:52,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:52,302 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,303 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 08:51:52,304 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:52,304 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:52,304 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:52,304 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-05-18 08:51:52,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1232105688_0005
2016-05-18 08:51:52,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:52,441 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:52,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:52,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:52,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABE84DF18137404ABC5846EE5B72B590, ordinal: 0
2016-05-18 08:51:52,465 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,466 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-05-18 08:51:52,466 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE84DF18137404ABC5846EE5B72B590, mem on start (mb), free: 167, total: 281, max: 672
2016-05-18 08:51:52,470 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABE84DF18137404ABC5846EE5B72B590, mem on close (mb), free: 167, total: 281, max: 672
2016-05-18 08:51:52,492 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-05-18 08:51:52,493 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.190
2016-05-18 08:51:52,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-05-18 08:51:52,582 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:52,583 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 08:51:52,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 08:51:52,625 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:52,626 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:52,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:52,638 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 08:51:52,639 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:52,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:52,640 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:52,641 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-05-18 08:51:52,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1110686914_0006
2016-05-18 08:51:52,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:52,749 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:52,756 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:52,756 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:52,767 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F56BAC406861413883EC386E620820AF, ordinal: 0
2016-05-18 08:51:52,767 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,768 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-05-18 08:51:52,768 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F56BAC406861413883EC386E620820AF, mem on start (mb), free: 325, total: 394, max: 672
2016-05-18 08:51:52,772 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F56BAC406861413883EC386E620820AF, mem on close (mb), free: 325, total: 394, max: 672
2016-05-18 08:51:52,788 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-05-18 08:51:52,789 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.150
2016-05-18 08:51:52,839 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-05-18 08:51:52,855 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:52,855 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 08:51:52,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.013
2016-05-18 08:51:52,873 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:52,873 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-05-18 08:51:52,886 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:52,886 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 08:51:52,918 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-18 08:51:52,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:52,919 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:52,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:52,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:52,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 08:51:52,930 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:52,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:52,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:52,931 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-05-18 08:51:53,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local474531254_0007
2016-05-18 08:51:53,036 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:53,040 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:53,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:53,046 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:53,055 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B6DFC3D0AE6A45FD9DAD44EAFD1456B0, ordinal: 0
2016-05-18 08:51:53,056 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,056 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-05-18 08:51:53,056 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6DFC3D0AE6A45FD9DAD44EAFD1456B0, mem on start (mb), free: 246, total: 394, max: 672
2016-05-18 08:51:53,059 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B6DFC3D0AE6A45FD9DAD44EAFD1456B0, mem on close (mb), free: 246, total: 394, max: 672
2016-05-18 08:51:53,080 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-05-18 08:51:53,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.150
2016-05-18 08:51:53,137 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-05-18 08:51:53,156 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:53,156 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 08:51:53,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 08:51:53,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:53,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:53,205 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:53,206 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-05-18 08:51:53,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1773978255_0008
2016-05-18 08:51:53,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:53,333 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:53,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:53,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:53,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A25D393CD6C1413999B9FC4C4380F626, ordinal: 0
2016-05-18 08:51:53,348 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,348 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-05-18 08:51:53,348 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A25D393CD6C1413999B9FC4C4380F626, mem on start (mb), free: 174, total: 394, max: 672
2016-05-18 08:51:53,351 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A25D393CD6C1413999B9FC4C4380F626, mem on close (mb), free: 174, total: 394, max: 672
2016-05-18 08:51:53,372 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-05-18 08:51:53,373 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.167
2016-05-18 08:51:53,458 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-05-18 08:51:53,472 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:53,472 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 08:51:53,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 08:51:53,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:53,513 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:53,525 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:53,525 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 08:51:53,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:53,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:53,526 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:53,527 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 08:51:53,617 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1026452762_0009
2016-05-18 08:51:53,617 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:53,622 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:53,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:53,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:53,635 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B9E638573F834C248C03C7F39FE730A2, ordinal: 0
2016-05-18 08:51:53,635 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,636 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-05-18 08:51:53,636 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9E638573F834C248C03C7F39FE730A2, mem on start (mb), free: 322, total: 389, max: 672
2016-05-18 08:51:53,638 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9E638573F834C248C03C7F39FE730A2, mem on close (mb), free: 322, total: 389, max: 672
2016-05-18 08:51:53,652 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-05-18 08:51:53,653 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.127
2016-05-18 08:51:53,699 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-05-18 08:51:53,713 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:53,713 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 08:51:53,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 08:51:53,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:53,742 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:53,756 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:53,756 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 08:51:53,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:53,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:53,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:53,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 08:51:53,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1753648771_0010
2016-05-18 08:51:53,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:53,859 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:53,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:53,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:53,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A09DF7FD1AD84EE08F735EB174553C3D, ordinal: 0
2016-05-18 08:51:53,875 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,875 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-05-18 08:51:53,875 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A09DF7FD1AD84EE08F735EB174553C3D, mem on start (mb), free: 249, total: 389, max: 672
2016-05-18 08:51:53,877 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:53,880 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:53,882 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:53,882 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A09DF7FD1AD84EE08F735EB174553C3D, mem on close (mb), free: 249, total: 389, max: 672
2016-05-18 08:51:53,883 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1753648771_0010
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:53,888 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local1753648771_0010 state at FAILED
2016-05-18 08:51:53,888 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:53,889 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:53,889 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:53,890 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:53,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-05-18 08:51:53,891 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:53,891 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-05-18 08:51:53,892 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.135
2016-05-18 08:51:53,892 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-05-18 08:51:53,904 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:53,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 08:51:53,922 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.014
2016-05-18 08:51:53,923 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:53,923 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-05-18 08:51:53,943 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:53,943 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 08:51:53,974 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-18 08:51:53,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:53,975 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:53,989 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:53,989 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:53,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 08:51:53,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:53,991 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:53,992 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:53,993 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 08:51:54,103 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1392663862_0011
2016-05-18 08:51:54,103 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:54,107 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:54,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:54,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:54,124 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AC8EEA56E1CC4296BE91FA10CB8ECD26, ordinal: 0
2016-05-18 08:51:54,125 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,125 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-05-18 08:51:54,125 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC8EEA56E1CC4296BE91FA10CB8ECD26, mem on start (mb), free: 185, total: 389, max: 672
2016-05-18 08:51:54,126 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,128 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,132 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,136 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC8EEA56E1CC4296BE91FA10CB8ECD26, mem on close (mb), free: 185, total: 389, max: 672
2016-05-18 08:51:54,137 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1392663862_0011
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:54,147 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local1392663862_0011 state at FAILED
2016-05-18 08:51:54,147 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:54,147 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:54,147 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:54,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:54,148 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-05-18 08:51:54,149 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:54,149 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-05-18 08:51:54,150 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.160
2016-05-18 08:51:54,150 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-05-18 08:51:54,165 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,165 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 08:51:54,190 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 08:51:54,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:54,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:54,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:54,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 08:51:54,307 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local591695811_0012
2016-05-18 08:51:54,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:54,313 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:54,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:54,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:54,332 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B963AF904A2646B6B8D96B3554C7F8FA, ordinal: 0
2016-05-18 08:51:54,333 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,333 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-05-18 08:51:54,333 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B963AF904A2646B6B8D96B3554C7F8FA, mem on start (mb), free: 360, total: 394, max: 672
2016-05-18 08:51:54,334 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,335 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,339 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:54,342 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B963AF904A2646B6B8D96B3554C7F8FA, mem on close (mb), free: 360, total: 394, max: 672
2016-05-18 08:51:54,343 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local591695811_0012
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:54,349 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local591695811_0012 state at FAILED
2016-05-18 08:51:54,349 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:54,350 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:54,350 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:54,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:54,350 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-05-18 08:51:54,351 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:54,351 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-05-18 08:51:54,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.151
2016-05-18 08:51:54,352 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-05-18 08:51:54,367 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,368 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 08:51:54,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 08:51:54,380 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:54,380 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-05-18 08:51:54,393 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,393 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 08:51:54,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 08:51:54,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:54,428 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:54,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:54,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 08:51:54,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:54,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:54,437 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:54,438 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-05-18 08:51:54,524 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local862919994_0013
2016-05-18 08:51:54,525 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:54,529 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:54,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:54,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:54,541 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D6541F25B0954A1C8A8A21AF5A285F63, ordinal: 0
2016-05-18 08:51:54,542 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,542 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-05-18 08:51:54,542 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6541F25B0954A1C8A8A21AF5A285F63, mem on start (mb), free: 295, total: 394, max: 672
2016-05-18 08:51:54,545 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6541F25B0954A1C8A8A21AF5A285F63, mem on close (mb), free: 295, total: 394, max: 672
2016-05-18 08:51:54,564 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-05-18 08:51:54,564 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.128
2016-05-18 08:51:54,611 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-05-18 08:51:54,632 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,633 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 08:51:54,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-05-18 08:51:54,651 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:54,652 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-05-18 08:51:54,671 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,671 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 08:51:54,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 08:51:54,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:54,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:54,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:54,717 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 08:51:54,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:54,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:54,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:54,720 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-05-18 08:51:54,815 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local415918515_0014
2016-05-18 08:51:54,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:54,821 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:54,826 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:54,826 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:54,833 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A4F7B300626A4E61B9C25CCBFB7AFB34, ordinal: 0
2016-05-18 08:51:54,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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,834 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-05-18 08:51:54,835 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A4F7B300626A4E61B9C25CCBFB7AFB34, mem on start (mb), free: 216, total: 394, max: 672
2016-05-18 08:51:54,838 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A4F7B300626A4E61B9C25CCBFB7AFB34, mem on close (mb), free: 216, total: 394, max: 672
2016-05-18 08:51:54,851 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-05-18 08:51:54,851 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.133
2016-05-18 08:51:54,895 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-05-18 08:51:54,908 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:54,908 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 08:51:54,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 08:51:54,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:54,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:54,942 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:54,943 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:54,943 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 08:51:54,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:54,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:54,944 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:54,946 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-05-18 08:51:55,047 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1925219747_0015
2016-05-18 08:51:55,048 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:55,052 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:55,057 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:55,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:55,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9B85C18C18249DD8DD2F67146CAD05F, ordinal: 0
2016-05-18 08:51:55,067 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,068 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-05-18 08:51:55,069 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9B85C18C18249DD8DD2F67146CAD05F, mem on start (mb), free: 370, total: 394, max: 672
2016-05-18 08:51:55,071 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9B85C18C18249DD8DD2F67146CAD05F, mem on close (mb), free: 370, total: 394, max: 672
2016-05-18 08:51:55,092 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-05-18 08:51:55,092 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.149
2016-05-18 08:51:55,135 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-05-18 08:51:55,147 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:55,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 08:51:55,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 08:51:55,174 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:55,174 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:55,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:55,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 08:51:55,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:55,183 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:55,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:55,184 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-05-18 08:51:55,314 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local709228467_0016
2016-05-18 08:51:55,315 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:55,322 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:55,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:55,329 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:55,336 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C5BFCDE1C6A34EB180AAA1994E5039E4, ordinal: 0
2016-05-18 08:51:55,336 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,337 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-05-18 08:51:55,337 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C5BFCDE1C6A34EB180AAA1994E5039E4, mem on start (mb), free: 302, total: 394, max: 672
2016-05-18 08:51:55,340 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C5BFCDE1C6A34EB180AAA1994E5039E4, mem on close (mb), free: 302, total: 394, max: 672
2016-05-18 08:51:55,359 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-05-18 08:51:55,360 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.176
2016-05-18 08:51:55,422 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-05-18 08:51:55,443 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:55,443 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 08:51:55,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 08:51:55,470 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:55,471 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:55,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:55,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,480 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 08:51:55,481 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:55,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:55,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:55,482 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-05-18 08:51:55,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local2136008331_0017
2016-05-18 08:51:55,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:55,581 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:55,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:55,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:55,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1292E3F268B45829CAD637862080484, ordinal: 0
2016-05-18 08:51:55,595 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,595 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-05-18 08:51:55,596 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1292E3F268B45829CAD637862080484, mem on start (mb), free: 236, total: 394, max: 672
2016-05-18 08:51:55,599 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1292E3F268B45829CAD637862080484, mem on close (mb), free: 236, total: 394, max: 672
2016-05-18 08:51:55,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-05-18 08:51:55,611 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.131
2016-05-18 08:51:55,654 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-05-18 08:51:55,668 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:55,668 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 08:51:55,694 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 08:51:55,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:55,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:55,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:55,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 08:51:55,704 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:55,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:55,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:55,705 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-05-18 08:51:55,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local385801568_0018
2016-05-18 08:51:55,804 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:55,808 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:55,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:55,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:55,826 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D82592F58A234030A1F16DE5C13754A2, ordinal: 0
2016-05-18 08:51:55,827 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,827 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-05-18 08:51:55,827 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D82592F58A234030A1F16DE5C13754A2, mem on start (mb), free: 169, total: 394, max: 672
2016-05-18 08:51:55,831 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D82592F58A234030A1F16DE5C13754A2, mem on close (mb), free: 169, total: 394, max: 672
2016-05-18 08:51:55,847 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-05-18 08:51:55,849 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.143
2016-05-18 08:51:55,909 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-05-18 08:51:55,926 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:55,927 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 08:51:55,939 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 08:51:55,939 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:55,939 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-05-18 08:51:55,955 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:55,955 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 08:51:55,972 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 08:51:55,973 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:55,973 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:55,981 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:55,981 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:55,981 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 08:51:55,981 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:55,982 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:55,982 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:55,982 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-05-18 08:51:56,069 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local128283854_0019
2016-05-18 08:51:56,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:56,074 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:56,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:56,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:56,086 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEA440856A65497A9628B92EBF5673AF, ordinal: 0
2016-05-18 08:51:56,087 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,087 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-05-18 08:51:56,087 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEA440856A65497A9628B92EBF5673AF, mem on start (mb), free: 325, total: 395, max: 672
2016-05-18 08:51:56,090 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEA440856A65497A9628B92EBF5673AF, mem on close (mb), free: 325, total: 395, max: 672
2016-05-18 08:51:56,104 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-05-18 08:51:56,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.123
2016-05-18 08:51:56,147 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-05-18 08:51:56,161 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,161 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 08:51:56,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 08:51:56,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:56,187 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:56,198 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:56,198 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 08:51:56,199 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:56,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:56,200 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:56,201 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-05-18 08:51:56,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1954512675_0020
2016-05-18 08:51:56,292 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:56,296 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:56,301 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:56,301 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:56,308 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B54ACE1CBE994DEC9FB0D72BF4243B64, ordinal: 0
2016-05-18 08:51:56,309 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,309 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-05-18 08:51:56,309 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B54ACE1CBE994DEC9FB0D72BF4243B64, mem on start (mb), free: 260, total: 395, max: 672
2016-05-18 08:51:56,312 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B54ACE1CBE994DEC9FB0D72BF4243B64, mem on close (mb), free: 260, total: 395, max: 672
2016-05-18 08:51:56,327 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-05-18 08:51:56,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.128
2016-05-18 08:51:56,374 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-05-18 08:51:56,387 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,388 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 08:51:56,408 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-05-18 08:51:56,409 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:56,409 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:56,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:56,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 08:51:56,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:56,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:56,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:56,421 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 08:51:56,521 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local745419617_0021
2016-05-18 08:51:56,522 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:56,526 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:56,531 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:56,531 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:56,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A757A2AD4912407796EBE44B974FC0E8, ordinal: 0
2016-05-18 08:51:56,540 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,540 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-05-18 08:51:56,540 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A757A2AD4912407796EBE44B974FC0E8, mem on start (mb), free: 194, total: 395, max: 672
2016-05-18 08:51:56,541 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,543 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,543 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,553 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A757A2AD4912407796EBE44B974FC0E8, mem on close (mb), free: 194, total: 395, max: 672
2016-05-18 08:51:56,555 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local745419617_0021
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:56,563 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local745419617_0021 state at FAILED
2016-05-18 08:51:56,564 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:56,564 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:56,564 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:56,567 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:56,567 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-05-18 08:51:56,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:56,568 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-05-18 08:51:56,568 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.149
2016-05-18 08:51:56,569 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-05-18 08:51:56,587 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,588 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 08:51:56,602 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2016-05-18 08:51:56,602 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:56,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-05-18 08:51:56,614 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,614 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 08:51:56,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 08:51:56,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:56,633 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:56,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:56,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,643 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 08:51:56,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:56,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:56,644 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:56,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 08:51:56,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1396471197_0022
2016-05-18 08:51:56,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:56,749 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:56,754 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:56,754 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:56,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0C0F88FA5E04B83B1D35B62E4D6FE35, ordinal: 0
2016-05-18 08:51:56,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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,762 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-05-18 08:51:56,763 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0C0F88FA5E04B83B1D35B62E4D6FE35, mem on start (mb), free: 359, total: 388, max: 672
2016-05-18 08:51:56,764 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,766 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,770 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,776 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0C0F88FA5E04B83B1D35B62E4D6FE35, mem on close (mb), free: 359, total: 388, max: 672
2016-05-18 08:51:56,778 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1396471197_0022
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:56,786 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local1396471197_0022 state at FAILED
2016-05-18 08:51:56,786 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:56,786 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:56,786 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:56,786 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:56,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-05-18 08:51:56,787 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:56,787 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-05-18 08:51:56,788 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.145
2016-05-18 08:51:56,788 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-05-18 08:51:56,802 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,803 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 08:51:56,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 08:51:56,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:56,824 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:56,831 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:56,831 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,832 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 08:51:56,832 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:56,832 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:56,832 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:56,833 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 08:51:56,918 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1444854800_0023
2016-05-18 08:51:56,918 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:56,922 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:56,927 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:56,928 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:56,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D6AB00A27AB94742B021DC4B70388829, ordinal: 0
2016-05-18 08:51:56,935 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:56,936 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-05-18 08:51:56,936 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6AB00A27AB94742B021DC4B70388829, mem on start (mb), free: 306, total: 388, max: 672
2016-05-18 08:51:56,937 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,941 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,943 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.pipe.OperatorException: [every.every][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:450)
	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 08:51:56,944 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D6AB00A27AB94742B021DC4B70388829, mem on close (mb), free: 306, total: 388, max: 672
2016-05-18 08:51:56,945 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1444854800_0023
java.lang.Exception: cascading.pipe.OperatorException: [every.every][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: [every.every][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:450)
	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 08:51:56,953 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] hadoop job job_local1444854800_0023 state at FAILED
2016-05-18 08:51:56,953 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] failure info: NA
2016-05-18 08:51:56,953 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events identify failed tasks
2016-05-18 08:51:56,953 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [every.every] task completion events count: 0
2016-05-18 08:51:56,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping all jobs
2016-05-18 08:51:56,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-05-18 08:51:56,955 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] stopped all jobs
2016-05-18 08:51:56,956 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-05-18 08:51:56,956 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.124
2016-05-18 08:51:56,956 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-05-18 08:51:56,970 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:56,971 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 08:51:56,996 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 08:51:56,997 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:56,997 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:57,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:57,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 08:51:57,004 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:57,005 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:57,005 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:57,005 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-05-18 08:51:57,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local509166314_0024
2016-05-18 08:51:57,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:57,093 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:57,097 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:57,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:57,105 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7BDC227098949AE9A5204B0D5C543B7, ordinal: 0
2016-05-18 08:51:57,106 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,106 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-05-18 08:51:57,106 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7BDC227098949AE9A5204B0D5C543B7, mem on start (mb), free: 255, total: 388, max: 672
2016-05-18 08:51:57,109 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7BDC227098949AE9A5204B0D5C543B7, mem on close (mb), free: 255, total: 388, max: 672
2016-05-18 08:51:57,124 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-05-18 08:51:57,124 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.120
2016-05-18 08:51:57,173 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-05-18 08:51:57,187 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,188 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 08:51:57,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-05-18 08:51:57,197 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:57,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-05-18 08:51:57,210 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,210 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 08:51:57,226 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 08:51:57,227 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:57,227 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:57,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:57,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 08:51:57,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:57,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:57,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:57,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-05-18 08:51:57,318 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local188927889_0025
2016-05-18 08:51:57,319 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:57,322 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:57,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:57,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:57,332 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DCBB880C27924A1C805AB389D12EFD70, ordinal: 0
2016-05-18 08:51:57,333 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,333 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-05-18 08:51:57,333 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCBB880C27924A1C805AB389D12EFD70, mem on start (mb), free: 184, total: 388, max: 672
2016-05-18 08:51:57,338 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DCBB880C27924A1C805AB389D12EFD70, mem on close (mb), free: 184, total: 388, max: 672
2016-05-18 08:51:57,351 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-05-18 08:51:57,352 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.118
2016-05-18 08:51:57,396 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-05-18 08:51:57,409 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,410 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 08:51:57,418 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-05-18 08:51:57,419 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:57,419 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-05-18 08:51:57,431 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,431 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 08:51:57,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 08:51:57,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:57,449 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:57,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:57,455 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 08:51:57,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:57,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:57,457 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:57,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-05-18 08:51:57,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1489817032_0026
2016-05-18 08:51:57,562 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:57,567 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:57,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:57,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:57,581 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E7929809E897424EA4F295AC7A28E7E3, ordinal: 0
2016-05-18 08:51:57,582 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,582 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-05-18 08:51:57,582 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7929809E897424EA4F295AC7A28E7E3, mem on start (mb), free: 332, total: 379, max: 672
2016-05-18 08:51:57,585 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7929809E897424EA4F295AC7A28E7E3, mem on close (mb), free: 332, total: 379, max: 672
2016-05-18 08:51:57,607 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-05-18 08:51:57,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.151
2016-05-18 08:51:57,654 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-05-18 08:51:57,673 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,673 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 08:51:57,695 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-05-18 08:51:57,696 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:57,696 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:57,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:57,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,706 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 08:51:57,707 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:57,707 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:57,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:57,709 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-05-18 08:51:57,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local298329038_0027
2016-05-18 08:51:57,801 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:57,805 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:57,809 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:57,809 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:57,816 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1F147C580A74BE7899B583D4FE92855, ordinal: 0
2016-05-18 08:51:57,816 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,816 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-05-18 08:51:57,816 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1F147C580A74BE7899B583D4FE92855, mem on start (mb), free: 265, total: 379, max: 672
2016-05-18 08:51:57,819 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1F147C580A74BE7899B583D4FE92855, mem on close (mb), free: 265, total: 379, max: 672
2016-05-18 08:51:57,835 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-05-18 08:51:57,835 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.129
2016-05-18 08:51:57,879 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-05-18 08:51:57,891 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:57,891 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 08:51:57,907 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 08:51:57,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:57,908 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:57,914 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:57,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:57,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 08:51:57,915 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:57,916 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:57,916 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:57,917 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-05-18 08:51:58,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local2139124744_0028
2016-05-18 08:51:58,002 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:58,005 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:58,011 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:58,011 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:58,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5B144CD7D2D424FB617F324B32EB262, ordinal: 0
2016-05-18 08:51:58,017 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,018 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-05-18 08:51:58,018 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B144CD7D2D424FB617F324B32EB262, mem on start (mb), free: 199, total: 379, max: 672
2016-05-18 08:51:58,021 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B144CD7D2D424FB617F324B32EB262, mem on close (mb), free: 199, total: 379, max: 672
2016-05-18 08:51:58,035 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-05-18 08:51:58,035 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.120
2016-05-18 08:51:58,078 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-05-18 08:51:58,091 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:58,091 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 08:51:58,107 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 08:51:58,107 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:58,108 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:58,114 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:58,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 08:51:58,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:58,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:58,115 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:58,116 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-05-18 08:51:58,208 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local57393349_0029
2016-05-18 08:51:58,209 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:58,213 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:58,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:58,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:58,224 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E9B8EA1834444985928DE10C10A90469, ordinal: 0
2016-05-18 08:51:58,224 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,224 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-05-18 08:51:58,224 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9B8EA1834444985928DE10C10A90469, mem on start (mb), free: 344, total: 370, max: 672
2016-05-18 08:51:58,228 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9B8EA1834444985928DE10C10A90469, mem on close (mb), free: 344, total: 370, max: 672
2016-05-18 08:51:58,243 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-05-18 08:51:58,244 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.129
2016-05-18 08:51:58,287 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-05-18 08:51:58,301 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:58,302 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 08:51:58,319 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 08:51:58,320 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:58,321 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:58,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:58,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,331 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 08:51:58,332 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:58,332 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:58,332 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:58,333 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-05-18 08:51:58,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local1618755634_0030
2016-05-18 08:51:58,448 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:58,457 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:58,463 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:58,463 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:58,472 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EED84C732B114E2887DF9EC1D0F9373B, ordinal: 0
2016-05-18 08:51:58,473 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,474 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-05-18 08:51:58,474 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EED84C732B114E2887DF9EC1D0F9373B, mem on start (mb), free: 283, total: 370, max: 672
2016-05-18 08:51:58,478 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EED84C732B114E2887DF9EC1D0F9373B, mem on close (mb), free: 283, total: 370, max: 672
2016-05-18 08:51:58,499 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-05-18 08:51:58,500 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.168
2016-05-18 08:51:58,550 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-05-18 08:51:58,562 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:58,562 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 08:51:58,581 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-18 08:51:58,582 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 08:51:58,582 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 08:51:58,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting
2016-05-18 08:51:58,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 08:51:58,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  parallel execution of steps is enabled: false
2016-05-18 08:51:58,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  executing total steps: 1
2016-05-18 08:51:58,589 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  allocating management threads: 1
2016-05-18 08:51:58,589 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 08:51:58,682 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] submitted hadoop job: job_local412957207_0031
2016-05-18 08:51:58,682 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] tracking url: http://localhost:8080/
2016-05-18 08:51:58,685 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/classes/test/data/nums.20.txt
2016-05-18 08:51:58,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 08:51:58,690 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 08:51:58,696 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DD2A3FD047BB4A7BA0C829620E64C5FD, ordinal: 0
2016-05-18 08:51:58,696 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.6.x/build/classes/test/data/nums.20.txt"]
2016-05-18 08:51:58,697 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.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-05-18 08:51:58,697 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD2A3FD047BB4A7BA0C829620E64C5FD, mem on start (mb), free: 223, total: 370, max: 672
2016-05-18 08:51:58,700 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD2A3FD047BB4A7BA0C829620E64C5FD, mem on close (mb), free: 223, total: 370, max: 672
2016-05-18 08:51:58,717 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-05-18 08:51:58,718 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every]  completed in: 00:00.128
2016-05-18 08:51:58,758 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-05-18 08:51:58,770 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 08:51:58,771 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 08:51:58,782 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-05-18 08:51:58,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-18 08:51:58,783 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.6.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'