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'