Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

0

ignored

7.358s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.221s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.234s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 1.242s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.215s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.214s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.023s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.178s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.239s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.028s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.231s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.192s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.229s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.020s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.145s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.186s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.153s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.180s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.229s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.177s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.221s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.022s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.235s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.024s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.196s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.022s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.242s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.168s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.206s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.037s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.151s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.135s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.149s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.176s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.200s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.191s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.187s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.215s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.193s passed

Standard output

2015-11-23 16:31:18,234 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-11-23 16:31:18,249 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EveryEveryPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2015-11-23 16:31:18,502 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-11-23 16:31:18,869 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-11-23 16:31:18,942 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-11-23 16:31:18,985 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:18,986 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:19,029 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 020F680AA13343BDB2D41103A4C1CA51
2015-11-23 16:31:19,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2015-11-23 16:31:19,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:19,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:19,206 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-11-23 16:31:19,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:19,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:19,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-11-23 16:31:19,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:19,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:19,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:19,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-11-23 16:31:19,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local156311990_0001
2015-11-23 16:31:19,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:19,605 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:19,619 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:19,619 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:19,629 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD3E131695854249ACA3C77A49FCCDA5, ordinal: 0
2015-11-23 16:31:19,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:19,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-11-23 16:31:19,653 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD3E131695854249ACA3C77A49FCCDA5, mem on start (mb), free: 332, total: 356, max: 672
2015-11-23 16:31:19,660 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD3E131695854249ACA3C77A49FCCDA5, mem on close (mb), free: 331, total: 356, max: 672
2015-11-23 16:31:19,698 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-11-23 16:31:19,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.489
2015-11-23 16:31:19,742 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2015-11-23 16:31:19,759 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:19,759 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:19,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-11-23 16:31:19,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:19,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:19,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:19,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-11-23 16:31:19,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1481314588_0002
2015-11-23 16:31:19,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:19,896 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:19,903 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:19,903 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:19,914 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D18965C720CF44498A904FE26A86A734, ordinal: 0
2015-11-23 16:31:19,915 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:19,915 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-11-23 16:31:19,915 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18965C720CF44498A904FE26A86A734, mem on start (mb), free: 265, total: 356, max: 672
2015-11-23 16:31:19,917 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18965C720CF44498A904FE26A86A734, mem on close (mb), free: 265, total: 356, max: 672
2015-11-23 16:31:19,934 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-11-23 16:31:19,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.135
2015-11-23 16:31:19,977 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2015-11-23 16:31:19,993 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:19,993 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-11-23 16:31:20,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:20,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:20,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:20,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-11-23 16:31:20,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local17122969_0003
2015-11-23 16:31:20,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:20,122 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:20,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:20,129 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:20,137 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AD4014539C9A4581947838B9E45562BA, ordinal: 0
2015-11-23 16:31:20,137 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,138 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-11-23 16:31:20,138 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD4014539C9A4581947838B9E45562BA, mem on start (mb), free: 323, total: 356, max: 672
2015-11-23 16:31:20,139 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AD4014539C9A4581947838B9E45562BA, mem on close (mb), free: 323, total: 356, max: 672
2015-11-23 16:31:20,160 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-11-23 16:31:20,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.134
2015-11-23 16:31:20,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2015-11-23 16:31:20,211 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:20,212 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-11-23 16:31:20,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:20,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:20,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:20,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-11-23 16:31:20,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:20,240 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:20,241 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:20,241 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-11-23 16:31:20,327 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1512890508_0004
2015-11-23 16:31:20,327 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:20,331 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:20,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:20,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:20,347 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC99EE40DA2B42389EC82BBD51FB42C7, ordinal: 0
2015-11-23 16:31:20,348 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,348 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-11-23 16:31:20,348 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC99EE40DA2B42389EC82BBD51FB42C7, mem on start (mb), free: 264, total: 356, max: 672
2015-11-23 16:31:20,351 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC99EE40DA2B42389EC82BBD51FB42C7, mem on close (mb), free: 264, total: 356, max: 672
2015-11-23 16:31:20,370 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-11-23 16:31:20,370 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.129
2015-11-23 16:31:20,412 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-11-23 16:31:20,424 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:20,425 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-11-23 16:31:20,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:20,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:20,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:20,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-11-23 16:31:20,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1075585382_0005
2015-11-23 16:31:20,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:20,550 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:20,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:20,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:20,564 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B1E45EF03655435385F0A4EB90C2EFF9, ordinal: 0
2015-11-23 16:31:20,564 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,565 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-11-23 16:31:20,565 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1E45EF03655435385F0A4EB90C2EFF9, mem on start (mb), free: 381, total: 407, max: 672
2015-11-23 16:31:20,567 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B1E45EF03655435385F0A4EB90C2EFF9, mem on close (mb), free: 381, total: 407, max: 672
2015-11-23 16:31:20,578 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-11-23 16:31:20,578 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.127
2015-11-23 16:31:20,627 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2015-11-23 16:31:20,641 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:20,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-11-23 16:31:20,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:20,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:20,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:20,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-11-23 16:31:20,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1221040793_0006
2015-11-23 16:31:20,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:20,773 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:20,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:20,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:20,787 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA35D2201F3C4C2BBAF53BC55D3DA3C5, ordinal: 0
2015-11-23 16:31:20,788 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,788 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-11-23 16:31:20,789 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA35D2201F3C4C2BBAF53BC55D3DA3C5, mem on start (mb), free: 318, total: 407, max: 672
2015-11-23 16:31:20,792 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA35D2201F3C4C2BBAF53BC55D3DA3C5, mem on close (mb), free: 318, total: 407, max: 672
2015-11-23 16:31:20,812 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-11-23 16:31:20,812 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.136
2015-11-23 16:31:20,858 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-11-23 16:31:20,872 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:20,872 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2015-11-23 16:31:20,885 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:20,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-11-23 16:31:20,901 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:20,902 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:20,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-11-23 16:31:20,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:20,919 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:20,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:20,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:20,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-11-23 16:31:20,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:20,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:20,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:20,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-11-23 16:31:21,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local393515701_0007
2015-11-23 16:31:21,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:21,037 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:21,043 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:21,044 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:21,050 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1DEE691EDAD4749BE82ABBC6A89EF40, ordinal: 0
2015-11-23 16:31:21,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-11-23 16:31:21,051 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1DEE691EDAD4749BE82ABBC6A89EF40, mem on start (mb), free: 251, total: 407, max: 672
2015-11-23 16:31:21,054 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1DEE691EDAD4749BE82ABBC6A89EF40, mem on close (mb), free: 251, total: 407, max: 672
2015-11-23 16:31:21,075 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-11-23 16:31:21,076 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.146
2015-11-23 16:31:21,125 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-11-23 16:31:21,141 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,141 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2015-11-23 16:31:21,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:21,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:21,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:21,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-11-23 16:31:21,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local664980814_0008
2015-11-23 16:31:21,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:21,278 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:21,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:21,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:21,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F23BBE8B1418450C8A1B3BBC0AA97209, ordinal: 0
2015-11-23 16:31:21,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,291 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-11-23 16:31:21,292 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F23BBE8B1418450C8A1B3BBC0AA97209, mem on start (mb), free: 364, total: 407, max: 672
2015-11-23 16:31:21,294 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F23BBE8B1418450C8A1B3BBC0AA97209, mem on close (mb), free: 364, total: 407, max: 672
2015-11-23 16:31:21,306 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-11-23 16:31:21,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.135
2015-11-23 16:31:21,354 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-11-23 16:31:21,371 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,371 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,385 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.010
2015-11-23 16:31:21,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:21,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:21,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:21,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-11-23 16:31:21,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:21,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:21,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:21,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-11-23 16:31:21,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local30296315_0009
2015-11-23 16:31:21,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:21,472 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:21,477 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:21,477 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:21,481 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E9E65C12FA724B55A7BFBB912DCE2DEA, ordinal: 0
2015-11-23 16:31:21,482 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,482 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-11-23 16:31:21,482 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9E65C12FA724B55A7BFBB912DCE2DEA, mem on start (mb), free: 302, total: 407, max: 672
2015-11-23 16:31:21,483 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9E65C12FA724B55A7BFBB912DCE2DEA, mem on close (mb), free: 302, total: 407, max: 672
2015-11-23 16:31:21,501 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-11-23 16:31:21,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.109
2015-11-23 16:31:21,546 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-11-23 16:31:21,562 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,562 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2015-11-23 16:31:21,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:21,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-11-23 16:31:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:21,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:21,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:21,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-11-23 16:31:21,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1790025569_0010
2015-11-23 16:31:21,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:21,671 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:21,676 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:21,676 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:21,679 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF5105D9D3E641948AA7D3A02E4E69A3, ordinal: 0
2015-11-23 16:31:21,680 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,680 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-11-23 16:31:21,680 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF5105D9D3E641948AA7D3A02E4E69A3, mem on start (mb), free: 239, total: 407, max: 672
2015-11-23 16:31:21,681 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,683 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,684 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,684 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF5105D9D3E641948AA7D3A02E4E69A3, mem on close (mb), free: 239, total: 407, max: 672
2015-11-23 16:31:21,685 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1790025569_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,689 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1790025569_0010 state at FAILED
2015-11-23 16:31:21,689 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:21,690 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:21,690 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:21,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:21,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-11-23 16:31:21,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:21,691 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-11-23 16:31:21,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.102
2015-11-23 16:31:21,691 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2015-11-23 16:31:21,704 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,704 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.003
2015-11-23 16:31:21,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:21,712 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2015-11-23 16:31:21,724 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,725 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.010
2015-11-23 16:31:21,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:21,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:21,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:21,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-11-23 16:31:21,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:21,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:21,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:21,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-11-23 16:31:21,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local285372843_0011
2015-11-23 16:31:21,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:21,836 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:21,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:21,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:21,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA06545AFA4C42BAB53CDEBCE60E3840, ordinal: 0
2015-11-23 16:31:21,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-11-23 16:31:21,849 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA06545AFA4C42BAB53CDEBCE60E3840, mem on start (mb), free: 389, total: 435, max: 672
2015-11-23 16:31:21,850 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,851 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,851 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,851 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA06545AFA4C42BAB53CDEBCE60E3840, mem on close (mb), free: 389, total: 435, max: 672
2015-11-23 16:31:21,853 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local285372843_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:21,863 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local285372843_0011 state at FAILED
2015-11-23 16:31:21,863 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:21,863 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:21,863 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:21,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:21,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-11-23 16:31:21,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:21,864 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-11-23 16:31:21,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.119
2015-11-23 16:31:21,865 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-11-23 16:31:21,885 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:21,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:21,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2015-11-23 16:31:21,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:21,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:21,916 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:21,916 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:21,916 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-11-23 16:31:21,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:21,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:21,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:21,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-11-23 16:31:22,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local113948444_0012
2015-11-23 16:31:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:22,022 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:22,029 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:22,029 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:22,034 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C56AD5E0EAE94F1ABB691C28B5C215A2, ordinal: 0
2015-11-23 16:31:22,035 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,035 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-11-23 16:31:22,035 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56AD5E0EAE94F1ABB691C28B5C215A2, mem on start (mb), free: 338, total: 435, max: 672
2015-11-23 16:31:22,036 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:22,037 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:22,037 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:22,037 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C56AD5E0EAE94F1ABB691C28B5C215A2, mem on close (mb), free: 338, total: 435, max: 672
2015-11-23 16:31:22,040 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local113948444_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:22,048 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local113948444_0012 state at FAILED
2015-11-23 16:31:22,048 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:22,048 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:22,048 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:22,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:22,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-11-23 16:31:22,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:22,050 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-11-23 16:31:22,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.133
2015-11-23 16:31:22,050 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2015-11-23 16:31:22,063 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,064 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2015-11-23 16:31:22,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:22,074 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2015-11-23 16:31:22,090 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,090 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.009
2015-11-23 16:31:22,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:22,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:22,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:22,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-11-23 16:31:22,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:22,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:22,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:22,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-11-23 16:31:22,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1737654851_0013
2015-11-23 16:31:22,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:22,194 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:22,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:22,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:22,200 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EFD5CFDAFFD54BF5BF21276F29708660, ordinal: 0
2015-11-23 16:31:22,201 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,201 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-11-23 16:31:22,201 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFD5CFDAFFD54BF5BF21276F29708660, mem on start (mb), free: 282, total: 435, max: 672
2015-11-23 16:31:22,203 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EFD5CFDAFFD54BF5BF21276F29708660, mem on close (mb), free: 282, total: 435, max: 672
2015-11-23 16:31:22,215 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-11-23 16:31:22,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.105
2015-11-23 16:31:22,251 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-11-23 16:31:22,268 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,269 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.004
2015-11-23 16:31:22,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:22,278 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2015-11-23 16:31:22,290 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,291 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-11-23 16:31:22,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:22,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:22,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:22,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-11-23 16:31:22,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:22,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:22,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:22,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-11-23 16:31:22,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local287502515_0014
2015-11-23 16:31:22,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:22,422 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:22,427 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:22,427 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:22,431 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E7FC37ED9D9D4D01975699D25CAE3EF8, ordinal: 0
2015-11-23 16:31:22,431 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,432 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-11-23 16:31:22,432 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7FC37ED9D9D4D01975699D25CAE3EF8, mem on start (mb), free: 215, total: 435, max: 672
2015-11-23 16:31:22,433 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7FC37ED9D9D4D01975699D25CAE3EF8, mem on close (mb), free: 215, total: 435, max: 672
2015-11-23 16:31:22,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-11-23 16:31:22,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.135
2015-11-23 16:31:22,507 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2015-11-23 16:31:22,521 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,521 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.008
2015-11-23 16:31:22,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:22,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:22,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:22,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-11-23 16:31:22,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:22,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:22,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:22,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-11-23 16:31:22,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local271509752_0015
2015-11-23 16:31:22,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:22,629 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:22,634 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:22,634 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:22,637 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CA4CDF90418349E7A7EC40FD673B4E9A, ordinal: 0
2015-11-23 16:31:22,637 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,637 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-11-23 16:31:22,637 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA4CDF90418349E7A7EC40FD673B4E9A, mem on start (mb), free: 362, total: 434, max: 672
2015-11-23 16:31:22,639 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CA4CDF90418349E7A7EC40FD673B4E9A, mem on close (mb), free: 362, total: 434, max: 672
2015-11-23 16:31:22,651 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-11-23 16:31:22,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.111
2015-11-23 16:31:22,686 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2015-11-23 16:31:22,703 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,703 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.010
2015-11-23 16:31:22,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:22,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:22,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:22,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-11-23 16:31:22,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:22,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:22,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:22,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-11-23 16:31:22,828 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1087857679_0016
2015-11-23 16:31:22,828 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:22,834 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:22,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:22,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:22,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8CC7583D3C24F7CB8518AA132BFE8A3, ordinal: 0
2015-11-23 16:31:22,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,842 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-11-23 16:31:22,842 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8CC7583D3C24F7CB8518AA132BFE8A3, mem on start (mb), free: 300, total: 434, max: 672
2015-11-23 16:31:22,844 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8CC7583D3C24F7CB8518AA132BFE8A3, mem on close (mb), free: 300, total: 434, max: 672
2015-11-23 16:31:22,863 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-11-23 16:31:22,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.135
2015-11-23 16:31:22,907 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2015-11-23 16:31:22,926 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:22,926 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:22,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.008
2015-11-23 16:31:22,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:22,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:22,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:22,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-11-23 16:31:23,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1128703803_0017
2015-11-23 16:31:23,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:23,027 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:23,031 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:23,032 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:23,034 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2649E356A374FFCA9C10F6B3A86C79B, ordinal: 0
2015-11-23 16:31:23,034 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,034 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-11-23 16:31:23,035 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2649E356A374FFCA9C10F6B3A86C79B, mem on start (mb), free: 238, total: 434, max: 672
2015-11-23 16:31:23,036 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2649E356A374FFCA9C10F6B3A86C79B, mem on close (mb), free: 238, total: 434, max: 672
2015-11-23 16:31:23,047 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-11-23 16:31:23,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.099
2015-11-23 16:31:23,085 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2015-11-23 16:31:23,099 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,100 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.007
2015-11-23 16:31:23,111 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:23,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:23,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:23,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-11-23 16:31:23,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1349875211_0018
2015-11-23 16:31:23,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:23,251 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:23,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:23,256 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:23,260 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7720A964CE84303ABF9986DF54D56BC, ordinal: 0
2015-11-23 16:31:23,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-11-23 16:31:23,261 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7720A964CE84303ABF9986DF54D56BC, mem on start (mb), free: 401, total: 447, max: 672
2015-11-23 16:31:23,263 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7720A964CE84303ABF9986DF54D56BC, mem on close (mb), free: 401, total: 447, max: 672
2015-11-23 16:31:23,281 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-11-23 16:31:23,282 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.162
2015-11-23 16:31:23,326 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2015-11-23 16:31:23,340 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,341 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.004
2015-11-23 16:31:23,349 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:23,349 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-11-23 16:31:23,361 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,362 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-11-23 16:31:23,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:23,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:23,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:23,387 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-11-23 16:31:23,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local293498358_0019
2015-11-23 16:31:23,476 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:23,480 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:23,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:23,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:23,489 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB07D3FEE6D74687AFEAD6F330B1AE76, ordinal: 0
2015-11-23 16:31:23,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-11-23 16:31:23,490 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB07D3FEE6D74687AFEAD6F330B1AE76, mem on start (mb), free: 331, total: 447, max: 672
2015-11-23 16:31:23,492 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB07D3FEE6D74687AFEAD6F330B1AE76, mem on close (mb), free: 331, total: 447, max: 672
2015-11-23 16:31:23,510 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-11-23 16:31:23,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.124
2015-11-23 16:31:23,555 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-11-23 16:31:23,571 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,571 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.008
2015-11-23 16:31:23,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:23,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:23,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:23,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-11-23 16:31:23,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1593763476_0020
2015-11-23 16:31:23,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:23,663 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:23,667 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:23,667 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:23,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8ADCF697AA44EDC8E51112ACEB28ABD, ordinal: 0
2015-11-23 16:31:23,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-11-23 16:31:23,670 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8ADCF697AA44EDC8E51112ACEB28ABD, mem on start (mb), free: 268, total: 447, max: 672
2015-11-23 16:31:23,672 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8ADCF697AA44EDC8E51112ACEB28ABD, mem on close (mb), free: 268, total: 447, max: 672
2015-11-23 16:31:23,683 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-11-23 16:31:23,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.093
2015-11-23 16:31:23,723 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-11-23 16:31:23,739 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,739 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.008
2015-11-23 16:31:23,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:23,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:23,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:23,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-11-23 16:31:23,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:23,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:23,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:23,758 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-11-23 16:31:23,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local142958834_0021
2015-11-23 16:31:23,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:23,856 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:23,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:23,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:23,866 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F41C79224EDA4807B81630A52CA064E2, ordinal: 0
2015-11-23 16:31:23,866 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,866 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-11-23 16:31:23,866 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41C79224EDA4807B81630A52CA064E2, mem on start (mb), free: 205, total: 447, max: 672
2015-11-23 16:31:23,867 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:23,868 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:23,868 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:23,868 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41C79224EDA4807B81630A52CA064E2, mem on close (mb), free: 205, total: 447, max: 672
2015-11-23 16:31:23,870 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local142958834_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:23,872 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local142958834_0021 state at FAILED
2015-11-23 16:31:23,872 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:23,872 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:23,872 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:23,873 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:23,873 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-11-23 16:31:23,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:23,874 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-11-23 16:31:23,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.117
2015-11-23 16:31:23,875 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2015-11-23 16:31:23,903 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.005
2015-11-23 16:31:23,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:23,912 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2015-11-23 16:31:23,926 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:23,927 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:23,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-11-23 16:31:23,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:23,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:23,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:23,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-11-23 16:31:24,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1922422761_0022
2015-11-23 16:31:24,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,042 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,048 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,048 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:24,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E1AD3C0702FD4E9AAB8B5CF73E03DC4D, ordinal: 0
2015-11-23 16:31:24,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-11-23 16:31:24,052 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1AD3C0702FD4E9AAB8B5CF73E03DC4D, mem on start (mb), free: 369, total: 446, max: 672
2015-11-23 16:31:24,053 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,053 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,054 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,054 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E1AD3C0702FD4E9AAB8B5CF73E03DC4D, mem on close (mb), free: 369, total: 446, max: 672
2015-11-23 16:31:24,055 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1922422761_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,058 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1922422761_0022 state at FAILED
2015-11-23 16:31:24,059 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:24,059 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:24,059 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:24,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:24,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-11-23 16:31:24,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:24,060 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-11-23 16:31:24,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.111
2015-11-23 16:31:24,061 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2015-11-23 16:31:24,073 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,073 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.006
2015-11-23 16:31:24,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:24,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:24,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:24,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-11-23 16:31:24,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:24,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:24,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:24,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-11-23 16:31:24,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1335196720_0023
2015-11-23 16:31:24,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,177 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,183 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,183 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:24,186 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF77E12EF68349129921621C513275A2, ordinal: 0
2015-11-23 16:31:24,186 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,187 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-11-23 16:31:24,187 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF77E12EF68349129921621C513275A2, mem on start (mb), free: 315, total: 446, max: 672
2015-11-23 16:31:24,187 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,188 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,188 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,188 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF77E12EF68349129921621C513275A2, mem on close (mb), free: 315, total: 446, max: 672
2015-11-23 16:31:24,189 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1335196720_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	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.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:453)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
2015-11-23 16:31:24,194 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1335196720_0023 state at FAILED
2015-11-23 16:31:24,194 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-11-23 16:31:24,194 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-11-23 16:31:24,194 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-11-23 16:31:24,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-11-23 16:31:24,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-11-23 16:31:24,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-11-23 16:31:24,195 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-11-23 16:31:24,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.107
2015-11-23 16:31:24,196 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2015-11-23 16:31:24,211 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,211 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-11-23 16:31:24,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:24,226 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:24,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:24,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-11-23 16:31:24,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1111021624_0024
2015-11-23 16:31:24,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,362 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,367 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,367 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:24,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDCCA91A09A847699EBBA27E972769B0, ordinal: 0
2015-11-23 16:31:24,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-11-23 16:31:24,372 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDCCA91A09A847699EBBA27E972769B0, mem on start (mb), free: 262, total: 446, max: 672
2015-11-23 16:31:24,374 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDCCA91A09A847699EBBA27E972769B0, mem on close (mb), free: 262, total: 446, max: 672
2015-11-23 16:31:24,391 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-11-23 16:31:24,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.160
2015-11-23 16:31:24,431 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2015-11-23 16:31:24,446 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,446 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.004
2015-11-23 16:31:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:24,453 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2015-11-23 16:31:24,466 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,467 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.009
2015-11-23 16:31:24,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:24,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:24,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:24,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-11-23 16:31:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local960373607_0025
2015-11-23 16:31:24,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,576 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,582 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,582 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:24,586 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3E68DF9F5FC4F2FB616199053F02945, ordinal: 0
2015-11-23 16:31:24,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-11-23 16:31:24,587 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E68DF9F5FC4F2FB616199053F02945, mem on start (mb), free: 416, total: 449, max: 672
2015-11-23 16:31:24,589 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E68DF9F5FC4F2FB616199053F02945, mem on close (mb), free: 416, total: 449, max: 672
2015-11-23 16:31:24,605 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-11-23 16:31:24,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.118
2015-11-23 16:31:24,648 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2015-11-23 16:31:24,665 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,666 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.004
2015-11-23 16:31:24,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:24,673 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2015-11-23 16:31:24,686 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,686 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.009
2015-11-23 16:31:24,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:24,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:24,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:24,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-11-23 16:31:24,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:24,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:24,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:24,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-11-23 16:31:24,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local325334149_0026
2015-11-23 16:31:24,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,801 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,806 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:24,808 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3E2758DDF9D4304B41FA78AF5CDC414, ordinal: 0
2015-11-23 16:31:24,808 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,808 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-11-23 16:31:24,808 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E2758DDF9D4304B41FA78AF5CDC414, mem on start (mb), free: 346, total: 449, max: 672
2015-11-23 16:31:24,809 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E2758DDF9D4304B41FA78AF5CDC414, mem on close (mb), free: 346, total: 449, max: 672
2015-11-23 16:31:24,819 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-11-23 16:31:24,820 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.113
2015-11-23 16:31:24,864 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2015-11-23 16:31:24,879 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:24,880 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:24,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.010
2015-11-23 16:31:24,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:24,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:24,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:24,901 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-11-23 16:31:24,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1390580906_0027
2015-11-23 16:31:24,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:24,992 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:24,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:24,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:25,000 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D2E52232D91D4BA7A49ABCE6C0577ECB, ordinal: 0
2015-11-23 16:31:25,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-11-23 16:31:25,001 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E52232D91D4BA7A49ABCE6C0577ECB, mem on start (mb), free: 282, total: 449, max: 672
2015-11-23 16:31:25,003 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D2E52232D91D4BA7A49ABCE6C0577ECB, mem on close (mb), free: 282, total: 449, max: 672
2015-11-23 16:31:25,021 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-11-23 16:31:25,021 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.120
2015-11-23 16:31:25,064 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-11-23 16:31:25,077 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:25,077 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:25,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-11-23 16:31:25,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:25,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:25,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:25,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-11-23 16:31:25,183 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local987544425_0028
2015-11-23 16:31:25,183 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:25,187 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:25,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:25,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:25,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FA669D96F8B744129A3E9C26124DBE59, ordinal: 0
2015-11-23 16:31:25,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-11-23 16:31:25,194 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA669D96F8B744129A3E9C26124DBE59, mem on start (mb), free: 218, total: 449, max: 672
2015-11-23 16:31:25,195 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA669D96F8B744129A3E9C26124DBE59, mem on close (mb), free: 218, total: 449, max: 672
2015-11-23 16:31:25,206 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-11-23 16:31:25,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.106
2015-11-23 16:31:25,240 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2015-11-23 16:31:25,262 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:25,263 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:25,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.009
2015-11-23 16:31:25,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:25,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:25,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:25,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-11-23 16:31:25,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:25,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:25,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:25,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-11-23 16:31:25,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1884972086_0029
2015-11-23 16:31:25,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:25,380 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:25,386 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:25,386 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:25,389 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF930D0867134FC6B29C9997AFCF8668, ordinal: 0
2015-11-23 16:31:25,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-11-23 16:31:25,390 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF930D0867134FC6B29C9997AFCF8668, mem on start (mb), free: 380, total: 448, max: 672
2015-11-23 16:31:25,391 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF930D0867134FC6B29C9997AFCF8668, mem on close (mb), free: 380, total: 448, max: 672
2015-11-23 16:31:25,409 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-11-23 16:31:25,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.123
2015-11-23 16:31:25,454 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-11-23 16:31:25,469 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:25,469 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:25,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-11-23 16:31:25,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:25,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:25,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:25,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-11-23 16:31:25,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local387546133_0030
2015-11-23 16:31:25,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:25,569 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:25,575 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:25,575 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:25,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B4BDADA4C7E94D14BA45024F57F18D18, ordinal: 0
2015-11-23 16:31:25,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-11-23 16:31:25,579 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4BDADA4C7E94D14BA45024F57F18D18, mem on start (mb), free: 314, total: 448, max: 672
2015-11-23 16:31:25,581 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4BDADA4C7E94D14BA45024F57F18D18, mem on close (mb), free: 314, total: 448, max: 672
2015-11-23 16:31:25,597 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-11-23 16:31:25,598 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.107
2015-11-23 16:31:25,641 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2015-11-23 16:31:25,659 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:25,659 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:25,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.010
2015-11-23 16:31:25,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-11-23 16:31:25,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-11-23 16:31:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-11-23 16:31:25,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-11-23 16:31:25,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local689663113_0031
2015-11-23 16:31:25,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-11-23 16:31:25,773 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt
2015-11-23 16:31:25,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 16:31:25,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 16:31:25,780 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C0CF7CE8DA944E01B3FAF2731E56DFFD, ordinal: 0
2015-11-23 16:31:25,780 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/nums.20.txt"]
2015-11-23 16:31:25,780 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-11-23 16:31:25,781 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C0CF7CE8DA944E01B3FAF2731E56DFFD, mem on start (mb), free: 248, total: 448, max: 672
2015-11-23 16:31:25,781 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C0CF7CE8DA944E01B3FAF2731E56DFFD, mem on close (mb), free: 248, total: 448, max: 672
2015-11-23 16:31:25,791 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-11-23 16:31:25,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.111
2015-11-23 16:31:25,835 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-11-23 16:31:25,853 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 16:31:25,853 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-11-23 16:31:25,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.003
2015-11-23 16:31:25,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 16:31:25,861 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'