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'