Class cascading.detail.EachEachPipeAssemblyPlatformTest

all > cascading.detail > EachEachPipeAssemblyPlatformTest
40

tests
0

failures
0

ignored
17.866s

duration
100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.948s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.811s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 3.463s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.472s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.486s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.076s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.125s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.415s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.404s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.069s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.474s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.432s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.414s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.107s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.322s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.347s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.385s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.379s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.387s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.476s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.398s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.049s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.478s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.102s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.585s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.052s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.393s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.352s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.408s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.097s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.303s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.350s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.316s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.469s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.585s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.519s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.427s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.403s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.063s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.525s passed

Standard output

2015-08-12 19:22:42,026 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 19:22:42,100 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2015-08-12 19:22:42,727 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 19:22:43,651 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-12 19:22:43,881 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-08-12 19:22:44,026 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:44,029 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-08-12 19:22:44,244 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 8C4C5B0C48454424AF19829C7FD0DF08
2015-08-12 19:22:44,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.116
2015-08-12 19:22:44,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:44,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:44,733 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 19:22:44,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:44,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:44,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 19:22:44,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:44,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:44,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:44,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-12 19:22:45,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1229092843_0001
2015-08-12 19:22:45,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:45,820 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:45,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:45,854 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:45,871 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDE5261A957F4642BE1002F5060856BE, ordinal: 0
2015-08-12 19:22:45,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:45,957 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 19:22:45,960 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDE5261A957F4642BE1002F5060856BE, mem on start (mb), free: 109, total: 210, max: 672
2015-08-12 19:22:45,981 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDE5261A957F4642BE1002F5060856BE, mem on close (mb), free: 107, total: 210, max: 672
2015-08-12 19:22:46,056 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-12 19:22:46,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:01.317
2015-08-12 19:22:46,187 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2015-08-12 19:22:46,286 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:46,289 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-08-12 19:22:46,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.105
2015-08-12 19:22:46,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:46,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:46,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:46,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:46,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 19:22:46,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:46,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:46,493 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:46,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-12 19:22:46,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local104046335_0002
2015-08-12 19:22:46,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:46,784 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:46,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:46,806 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:46,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B825B56C83C9417D8B4786EC8C80B7C9, ordinal: 0
2015-08-12 19:22:46,821 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:46,822 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 19:22:46,822 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B825B56C83C9417D8B4786EC8C80B7C9, mem on start (mb), free: 156, total: 210, max: 672
2015-08-12 19:22:46,826 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B825B56C83C9417D8B4786EC8C80B7C9, mem on close (mb), free: 156, total: 210, max: 672
2015-08-12 19:22:46,861 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-12 19:22:46,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.380
2015-08-12 19:22:47,002 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-12 19:22:47,034 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:47,037 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-08-12 19:22:47,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.098
2015-08-12 19:22:47,157 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:47,157 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:47,204 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:47,205 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:47,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 19:22:47,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:47,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:47,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:47,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-12 19:22:47,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1133814303_0003
2015-08-12 19:22:47,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:47,690 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:47,698 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:47,699 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:47,714 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAC803FD399E4EB583111739D8850196, ordinal: 0
2015-08-12 19:22:47,718 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:47,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 19:22:47,719 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC803FD399E4EB583111739D8850196, mem on start (mb), free: 88, total: 210, max: 672
2015-08-12 19:22:47,727 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC803FD399E4EB583111739D8850196, mem on close (mb), free: 88, total: 210, max: 672
2015-08-12 19:22:47,756 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-12 19:22:47,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.551
2015-08-12 19:22:47,953 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-12 19:22:47,985 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:47,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-08-12 19:22:48,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-08-12 19:22:48,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:48,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:48,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:48,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:48,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 19:22:48,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:48,083 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:48,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:48,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-12 19:22:48,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local608616855_0004
2015-08-12 19:22:48,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:48,285 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:48,292 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:48,292 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:48,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BC5BCFFEC2D548F59E962D05D37D0855, ordinal: 0
2015-08-12 19:22:48,307 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:48,308 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 19:22:48,309 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC5BCFFEC2D548F59E962D05D37D0855, mem on start (mb), free: 240, total: 322, max: 672
2015-08-12 19:22:48,316 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BC5BCFFEC2D548F59E962D05D37D0855, mem on close (mb), free: 240, total: 322, max: 672
2015-08-12 19:22:48,343 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-12 19:22:48,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.262
2015-08-12 19:22:48,438 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-12 19:22:48,464 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:48,465 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-08-12 19:22:48,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 19:22:48,528 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:48,528 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:48,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:48,558 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:48,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 19:22:48,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:48,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:48,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:48,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-12 19:22:48,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local940104598_0005
2015-08-12 19:22:48,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:48,754 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:48,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:48,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:48,770 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FA74A8D1232142088FA80FF0B6CF17A4, ordinal: 0
2015-08-12 19:22:48,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:48,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 19:22:48,773 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA74A8D1232142088FA80FF0B6CF17A4, mem on start (mb), free: 155, total: 322, max: 672
2015-08-12 19:22:48,778 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FA74A8D1232142088FA80FF0B6CF17A4, mem on close (mb), free: 155, total: 322, max: 672
2015-08-12 19:22:48,816 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-12 19:22:48,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.259
2015-08-12 19:22:48,910 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-12 19:22:48,946 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:48,948 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-08-12 19:22:49,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-08-12 19:22:49,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:49,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:49,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:49,024 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:49,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 19:22:49,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:49,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:49,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:49,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-12 19:22:49,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local2008751592_0006
2015-08-12 19:22:49,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:49,222 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:49,232 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:49,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:49,239 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FBE3373366C0409CB20B6A30919DA514, ordinal: 0
2015-08-12 19:22:49,240 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:49,241 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 19:22:49,241 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FBE3373366C0409CB20B6A30919DA514, mem on start (mb), free: 302, total: 322, max: 672
2015-08-12 19:22:49,247 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FBE3373366C0409CB20B6A30919DA514, mem on close (mb), free: 302, total: 322, max: 672
2015-08-12 19:22:49,275 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-12 19:22:49,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.248
2015-08-12 19:22:49,386 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-12 19:22:49,418 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:49,422 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-08-12 19:22:49,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.022
2015-08-12 19:22:49,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:49,455 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-12 19:22:49,478 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:49,479 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-08-12 19:22:49,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-08-12 19:22:49,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:49,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:49,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:49,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:49,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 19:22:49,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:49,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:49,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:49,550 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-12 19:22:49,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local906606711_0007
2015-08-12 19:22:49,711 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:49,727 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:49,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:49,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:49,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FDE57812EBD44295B0FC8D1FC7071012, ordinal: 0
2015-08-12 19:22:49,742 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:49,743 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 19:22:49,743 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDE57812EBD44295B0FC8D1FC7071012, mem on start (mb), free: 218, total: 322, max: 672
2015-08-12 19:22:49,746 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FDE57812EBD44295B0FC8D1FC7071012, mem on close (mb), free: 218, total: 322, max: 672
2015-08-12 19:22:49,770 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-12 19:22:49,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.223
2015-08-12 19:22:49,859 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-12 19:22:49,886 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:49,888 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-08-12 19:22:49,927 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-08-12 19:22:49,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:49,928 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:49,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:49,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:49,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 19:22:49,952 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:49,952 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:49,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:49,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-12 19:22:50,131 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local736610051_0008
2015-08-12 19:22:50,132 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:50,140 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:50,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:50,147 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:50,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF7C31ACBA3C431FAF53A08B72EEBDFF, ordinal: 0
2015-08-12 19:22:50,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:50,158 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 19:22:50,159 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF7C31ACBA3C431FAF53A08B72EEBDFF, mem on start (mb), free: 143, total: 322, max: 672
2015-08-12 19:22:50,162 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF7C31ACBA3C431FAF53A08B72EEBDFF, mem on close (mb), free: 143, total: 322, max: 672
2015-08-12 19:22:50,180 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-12 19:22:50,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.231
2015-08-12 19:22:50,272 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-12 19:22:50,303 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:50,304 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-08-12 19:22:50,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2015-08-12 19:22:50,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:50,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:50,396 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:50,396 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:50,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 19:22:50,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:50,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:50,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:50,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 19:22:50,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local187715016_0009
2015-08-12 19:22:50,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:50,587 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:50,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:50,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:50,602 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADB9855C677A456CAC438BF541ADDC4E, ordinal: 0
2015-08-12 19:22:50,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:50,603 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 19:22:50,603 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADB9855C677A456CAC438BF541ADDC4E, mem on start (mb), free: 296, total: 321, max: 672
2015-08-12 19:22:50,606 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADB9855C677A456CAC438BF541ADDC4E, mem on close (mb), free: 296, total: 321, max: 672
2015-08-12 19:22:50,637 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-12 19:22:50,637 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.241
2015-08-12 19:22:50,705 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 19:22:50,729 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:50,729 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-08-12 19:22:50,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-08-12 19:22:50,775 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:50,776 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:50,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:50,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:50,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 19:22:50,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:50,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:50,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:50,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 19:22:50,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1228667055_0010
2015-08-12 19:22:50,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:50,974 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:50,984 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:50,984 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:50,990 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD93517F81D844B79C927E7A35BA8231, ordinal: 0
2015-08-12 19:22:50,993 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:50,993 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 19:22:50,993 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD93517F81D844B79C927E7A35BA8231, mem on start (mb), free: 220, total: 321, max: 672
2015-08-12 19:22:50,996 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,000 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,002 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,006 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD93517F81D844B79C927E7A35BA8231, mem on close (mb), free: 220, total: 321, max: 672
2015-08-12 19:22:51,008 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1228667055_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,014 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1228667055_0010 state at FAILED
2015-08-12 19:22:51,014 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:51,017 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:51,017 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:51,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:51,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 19:22:51,023 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:51,024 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-12 19:22:51,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.230
2015-08-12 19:22:51,026 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2015-08-12 19:22:51,099 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:51,104 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-08-12 19:22:51,132 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.021
2015-08-12 19:22:51,133 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:51,134 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-12 19:22:51,171 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:51,172 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-08-12 19:22:51,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2015-08-12 19:22:51,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:51,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:51,283 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:51,284 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:51,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 19:22:51,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:51,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:51,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:51,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 19:22:51,430 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local126195770_0011
2015-08-12 19:22:51,431 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:51,456 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:51,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:51,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:51,472 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A28FC3FB40EA416587B3C92F3D171767, ordinal: 0
2015-08-12 19:22:51,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:51,476 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 19:22:51,478 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A28FC3FB40EA416587B3C92F3D171767, mem on start (mb), free: 155, total: 321, max: 672
2015-08-12 19:22:51,479 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,496 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,499 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,506 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A28FC3FB40EA416587B3C92F3D171767, mem on close (mb), free: 155, total: 321, max: 672
2015-08-12 19:22:51,509 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local126195770_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,515 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local126195770_0011 state at FAILED
2015-08-12 19:22:51,516 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:51,516 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:51,516 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:51,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:51,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 19:22:51,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:51,519 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-12 19:22:51,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.236
2015-08-12 19:22:51,520 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-12 19:22:51,573 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:51,576 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-08-12 19:22:51,616 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:22:51,617 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:51,618 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:51,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:51,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:51,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 19:22:51,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:51,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:51,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:51,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 19:22:51,783 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local2119551455_0012
2015-08-12 19:22:51,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:51,792 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:51,804 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:51,804 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:51,813 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9D21CE473C7454D85EFB5194FBD9730, ordinal: 0
2015-08-12 19:22:51,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:51,816 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 19:22:51,818 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9D21CE473C7454D85EFB5194FBD9730, mem on start (mb), free: 98, total: 321, max: 672
2015-08-12 19:22:51,820 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,843 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,856 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,857 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9D21CE473C7454D85EFB5194FBD9730, mem on close (mb), free: 98, total: 321, max: 672
2015-08-12 19:22:51,861 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2119551455_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:51,862 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local2119551455_0012 state at FAILED
2015-08-12 19:22:51,862 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:51,862 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:51,862 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:51,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:51,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 19:22:51,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:51,866 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-12 19:22:51,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.222
2015-08-12 19:22:51,867 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-12 19:22:51,915 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:51,921 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-08-12 19:22:51,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2015-08-12 19:22:51,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:51,942 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-12 19:22:51,972 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:51,972 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-08-12 19:22:52,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-08-12 19:22:52,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:52,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:52,048 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:52,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:52,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 19:22:52,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:52,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:52,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:52,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-12 19:22:52,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1116346379_0013
2015-08-12 19:22:52,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:52,221 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:52,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:52,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:52,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D993C6B88B354844A6F8322245E705E7, ordinal: 0
2015-08-12 19:22:52,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:52,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 19:22:52,236 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D993C6B88B354844A6F8322245E705E7, mem on start (mb), free: 263, total: 322, max: 672
2015-08-12 19:22:52,240 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D993C6B88B354844A6F8322245E705E7, mem on close (mb), free: 263, total: 322, max: 672
2015-08-12 19:22:52,258 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-12 19:22:52,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.209
2015-08-12 19:22:52,356 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-12 19:22:52,435 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:52,436 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-08-12 19:22:52,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.022
2015-08-12 19:22:52,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:52,483 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-12 19:22:52,531 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:52,532 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-08-12 19:22:52,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-08-12 19:22:52,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:52,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:52,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:52,586 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:52,587 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 19:22:52,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:52,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:52,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:52,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-12 19:22:52,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local88865226_0014
2015-08-12 19:22:52,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:52,757 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:52,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:52,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:52,768 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFD0CEDD065046F3A042D827ADC945F8, ordinal: 0
2015-08-12 19:22:52,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:52,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 19:22:52,770 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFD0CEDD065046F3A042D827ADC945F8, mem on start (mb), free: 181, total: 322, max: 672
2015-08-12 19:22:52,773 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFD0CEDD065046F3A042D827ADC945F8, mem on close (mb), free: 181, total: 322, max: 672
2015-08-12 19:22:52,797 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-12 19:22:52,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.212
2015-08-12 19:22:52,871 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2015-08-12 19:22:52,897 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:52,899 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-08-12 19:22:52,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2015-08-12 19:22:52,968 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:52,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:52,983 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:52,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:52,985 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 19:22:52,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:52,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:52,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:52,990 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-12 19:22:53,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1009332927_0015
2015-08-12 19:22:53,129 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:53,136 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:53,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:53,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:53,149 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E072F94B8DAB49038C12DC086A81118D, ordinal: 0
2015-08-12 19:22:53,150 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:53,150 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 19:22:53,150 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E072F94B8DAB49038C12DC086A81118D, mem on start (mb), free: 108, total: 322, max: 672
2015-08-12 19:22:53,154 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E072F94B8DAB49038C12DC086A81118D, mem on close (mb), free: 108, total: 322, max: 672
2015-08-12 19:22:53,176 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-12 19:22:53,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.192
2015-08-12 19:22:53,249 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-12 19:22:53,280 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:53,282 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-08-12 19:22:53,332 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-08-12 19:22:53,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:53,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:53,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:53,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:53,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 19:22:53,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:53,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:53,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:53,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-12 19:22:53,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1544339370_0016
2015-08-12 19:22:53,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:53,525 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:53,537 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:53,537 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:53,543 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6E53700CE8A450CBAF3D42EBD606025, ordinal: 0
2015-08-12 19:22:53,544 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:53,545 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 19:22:53,546 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6E53700CE8A450CBAF3D42EBD606025, mem on start (mb), free: 253, total: 307, max: 672
2015-08-12 19:22:53,549 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6E53700CE8A450CBAF3D42EBD606025, mem on close (mb), free: 253, total: 307, max: 672
2015-08-12 19:22:53,573 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-12 19:22:53,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.221
2015-08-12 19:22:53,647 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-12 19:22:53,676 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:53,676 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-08-12 19:22:53,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-08-12 19:22:53,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:53,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:53,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:53,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:53,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 19:22:53,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:53,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:53,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:53,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-12 19:22:53,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1098017876_0017
2015-08-12 19:22:53,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:53,948 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:53,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:53,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:53,970 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9FB4D29F9874731AEFE611629FC83F5, ordinal: 0
2015-08-12 19:22:53,971 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:53,971 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 19:22:53,973 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9FB4D29F9874731AEFE611629FC83F5, mem on start (mb), free: 181, total: 307, max: 672
2015-08-12 19:22:53,978 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9FB4D29F9874731AEFE611629FC83F5, mem on close (mb), free: 181, total: 307, max: 672
2015-08-12 19:22:54,025 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-12 19:22:54,032 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.276
2015-08-12 19:22:54,123 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2015-08-12 19:22:54,167 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:54,178 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-08-12 19:22:54,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:22:54,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:54,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:54,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:54,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:54,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 19:22:54,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:54,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:54,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:54,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-12 19:22:54,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local817711185_0018
2015-08-12 19:22:54,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:54,389 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:54,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:54,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:54,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3A462F8A3A545C69E69B271A3DFE169, ordinal: 0
2015-08-12 19:22:54,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:54,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 19:22:54,407 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3A462F8A3A545C69E69B271A3DFE169, mem on start (mb), free: 111, total: 307, max: 672
2015-08-12 19:22:54,413 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3A462F8A3A545C69E69B271A3DFE169, mem on close (mb), free: 111, total: 307, max: 672
2015-08-12 19:22:54,441 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-12 19:22:54,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.210
2015-08-12 19:22:54,516 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-12 19:22:54,552 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:54,552 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-08-12 19:22:54,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2015-08-12 19:22:54,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:54,569 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-12 19:22:54,632 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:54,632 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-08-12 19:22:54,664 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 19:22:54,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:54,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:54,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:54,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:54,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 19:22:54,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:54,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:54,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:54,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-12 19:22:54,833 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local984197361_0019
2015-08-12 19:22:54,833 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:54,840 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:54,846 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:54,846 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:54,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BF52CA0B7A1B456989E1964CAE9E3D4E, ordinal: 0
2015-08-12 19:22:54,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:54,854 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 19:22:54,854 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BF52CA0B7A1B456989E1964CAE9E3D4E, mem on start (mb), free: 246, total: 296, max: 672
2015-08-12 19:22:54,857 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BF52CA0B7A1B456989E1964CAE9E3D4E, mem on close (mb), free: 246, total: 296, max: 672
2015-08-12 19:22:54,891 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-12 19:22:54,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.212
2015-08-12 19:22:54,978 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-12 19:22:55,002 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:55,003 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-08-12 19:22:55,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-08-12 19:22:55,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:55,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:55,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:55,056 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:55,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 19:22:55,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:55,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:55,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:55,062 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-12 19:22:55,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local172574911_0020
2015-08-12 19:22:55,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:55,201 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:55,208 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:55,209 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:55,220 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ADFE5E961A5848E58319F7EECD06B201, ordinal: 0
2015-08-12 19:22:55,223 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:55,224 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 19:22:55,224 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADFE5E961A5848E58319F7EECD06B201, mem on start (mb), free: 177, total: 296, max: 672
2015-08-12 19:22:55,229 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ADFE5E961A5848E58319F7EECD06B201, mem on close (mb), free: 177, total: 296, max: 672
2015-08-12 19:22:55,252 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-12 19:22:55,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.197
2015-08-12 19:22:55,331 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-12 19:22:55,357 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:55,359 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-08-12 19:22:55,384 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-08-12 19:22:55,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:55,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:55,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:55,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:55,415 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 19:22:55,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:55,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:55,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:55,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 19:22:55,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1243555756_0021
2015-08-12 19:22:55,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:55,587 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:55,599 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:55,599 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:55,605 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BAB57B7DF4A44595BCF59E7EFD7CEA60, ordinal: 0
2015-08-12 19:22:55,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:55,607 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 19:22:55,607 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAB57B7DF4A44595BCF59E7EFD7CEA60, mem on start (mb), free: 107, total: 296, max: 672
2015-08-12 19:22:55,608 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:55,614 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:55,619 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:55,621 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAB57B7DF4A44595BCF59E7EFD7CEA60, mem on close (mb), free: 106, total: 296, max: 672
2015-08-12 19:22:55,626 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1243555756_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:55,629 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1243555756_0021 state at FAILED
2015-08-12 19:22:55,629 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:55,629 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:55,629 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:55,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:55,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 19:22:55,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:55,633 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-12 19:22:55,634 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.219
2015-08-12 19:22:55,634 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2015-08-12 19:22:55,712 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:55,715 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-08-12 19:22:55,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2015-08-12 19:22:55,730 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:55,731 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-12 19:22:55,760 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:55,762 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-08-12 19:22:55,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-08-12 19:22:55,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:55,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:55,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:55,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:55,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 19:22:55,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:55,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:55,813 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:55,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 19:22:55,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1946581250_0022
2015-08-12 19:22:55,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:55,987 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:55,992 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:55,993 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:55,999 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B31C73FBFE864CD6B88FB49A5A85A714, ordinal: 0
2015-08-12 19:22:56,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:56,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 19:22:56,001 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B31C73FBFE864CD6B88FB49A5A85A714, mem on start (mb), free: 247, total: 287, max: 672
2015-08-12 19:22:56,003 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,003 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,017 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,023 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B31C73FBFE864CD6B88FB49A5A85A714, mem on close (mb), free: 247, total: 287, max: 672
2015-08-12 19:22:56,038 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1946581250_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,044 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1946581250_0022 state at FAILED
2015-08-12 19:22:56,045 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:56,045 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:56,045 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:56,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:56,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 19:22:56,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:56,046 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-12 19:22:56,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.245
2015-08-12 19:22:56,047 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-12 19:22:56,094 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:56,095 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-08-12 19:22:56,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-08-12 19:22:56,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:56,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:56,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:56,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:56,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 19:22:56,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:56,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:56,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:56,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 19:22:56,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1200066442_0023
2015-08-12 19:22:56,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:56,319 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:56,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:56,328 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:56,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED3D2690E9904B299F9EB1C57581B017, ordinal: 0
2015-08-12 19:22:56,335 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:56,337 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 19:22:56,340 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3D2690E9904B299F9EB1C57581B017, mem on start (mb), free: 195, total: 287, max: 672
2015-08-12 19:22:56,343 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,360 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,373 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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,373 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED3D2690E9904B299F9EB1C57581B017, mem on close (mb), free: 195, total: 287, max: 672
2015-08-12 19:22:56,378 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1200066442_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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-08-12 19:22:56,388 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1200066442_0023 state at FAILED
2015-08-12 19:22:56,388 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2015-08-12 19:22:56,389 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2015-08-12 19:22:56,389 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2015-08-12 19:22:56,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2015-08-12 19:22:56,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 19:22:56,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2015-08-12 19:22:56,397 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-12 19:22:56,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.263
2015-08-12 19:22:56,398 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2015-08-12 19:22:56,456 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:56,460 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-08-12 19:22:56,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-08-12 19:22:56,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:56,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:56,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:56,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:56,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 19:22:56,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:56,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:56,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:56,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-12 19:22:56,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1983069815_0024
2015-08-12 19:22:56,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:56,746 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:56,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:56,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:56,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F7E5723BA40445B78C5C48E182012F0E, ordinal: 0
2015-08-12 19:22:56,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:56,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 19:22:56,762 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7E5723BA40445B78C5C48E182012F0E, mem on start (mb), free: 144, total: 287, max: 672
2015-08-12 19:22:56,766 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7E5723BA40445B78C5C48E182012F0E, mem on close (mb), free: 144, total: 287, max: 672
2015-08-12 19:22:56,780 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-12 19:22:56,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.249
2015-08-12 19:22:56,875 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2015-08-12 19:22:56,907 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:56,909 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-08-12 19:22:56,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2015-08-12 19:22:56,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:56,925 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-12 19:22:56,958 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:56,960 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-08-12 19:22:56,996 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-08-12 19:22:56,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:56,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:57,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:57,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:57,010 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 19:22:57,010 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:57,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:57,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:57,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-12 19:22:57,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1362140311_0025
2015-08-12 19:22:57,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:57,160 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:57,166 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:57,166 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:57,174 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C304712E160C4B63B57BDD23A0A80806, ordinal: 0
2015-08-12 19:22:57,175 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:57,176 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 19:22:57,177 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C304712E160C4B63B57BDD23A0A80806, mem on start (mb), free: 71, total: 287, max: 672
2015-08-12 19:22:57,180 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C304712E160C4B63B57BDD23A0A80806, mem on close (mb), free: 71, total: 287, max: 672
2015-08-12 19:22:57,227 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-12 19:22:57,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.218
2015-08-12 19:22:57,510 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-12 19:22:57,594 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:57,594 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-08-12 19:22:57,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.010
2015-08-12 19:22:57,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:22:57,612 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2015-08-12 19:22:57,642 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:57,643 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-08-12 19:22:57,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:22:57,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:57,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:57,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:57,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:57,692 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 19:22:57,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:57,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:57,694 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:57,695 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-12 19:22:57,914 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1713459667_0026
2015-08-12 19:22:57,916 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:57,944 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:57,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:57,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:57,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A82244C5FB3A44389E0791DA0D5FC0DC, ordinal: 0
2015-08-12 19:22:57,982 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:57,982 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 19:22:57,983 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A82244C5FB3A44389E0791DA0D5FC0DC, mem on start (mb), free: 218, total: 309, max: 672
2015-08-12 19:22:57,988 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A82244C5FB3A44389E0791DA0D5FC0DC, mem on close (mb), free: 218, total: 309, max: 672
2015-08-12 19:22:58,021 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-12 19:22:58,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.331
2015-08-12 19:22:58,131 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-12 19:22:58,151 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:58,152 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-08-12 19:22:58,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-08-12 19:22:58,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:58,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:58,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:58,226 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:58,227 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 19:22:58,228 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:58,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:58,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:58,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-12 19:22:58,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local635200563_0027
2015-08-12 19:22:58,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:58,478 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:58,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:58,486 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:58,494 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E57C139AFF44421B8648B8551A4144EE, ordinal: 0
2015-08-12 19:22:58,498 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:58,499 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 19:22:58,500 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E57C139AFF44421B8648B8551A4144EE, mem on start (mb), free: 153, total: 309, max: 672
2015-08-12 19:22:58,504 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E57C139AFF44421B8648B8551A4144EE, mem on close (mb), free: 152, total: 309, max: 672
2015-08-12 19:22:58,541 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-12 19:22:58,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.315
2015-08-12 19:22:58,716 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-12 19:22:58,743 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:58,744 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-08-12 19:22:58,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 19:22:58,778 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:58,779 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:58,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:58,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:58,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 19:22:58,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:58,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:58,809 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:58,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-12 19:22:59,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1567425588_0028
2015-08-12 19:22:59,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:59,048 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:59,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:59,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:59,059 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D453DB8826F94F1D99E2B18A84711331, ordinal: 0
2015-08-12 19:22:59,060 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:59,060 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 19:22:59,061 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D453DB8826F94F1D99E2B18A84711331, mem on start (mb), free: 86, total: 309, max: 672
2015-08-12 19:22:59,065 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D453DB8826F94F1D99E2B18A84711331, mem on close (mb), free: 85, total: 309, max: 672
2015-08-12 19:22:59,086 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-12 19:22:59,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.291
2015-08-12 19:22:59,186 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-12 19:22:59,221 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:59,222 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-08-12 19:22:59,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-08-12 19:22:59,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:59,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:59,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:59,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:59,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 19:22:59,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:59,293 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-12 19:22:59,439 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1783764941_0029
2015-08-12 19:22:59,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:59,451 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:59,467 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:59,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:59,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA6B7FDE43B64399B76788FD0A26A707, ordinal: 0
2015-08-12 19:22:59,474 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:59,474 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 19:22:59,475 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA6B7FDE43B64399B76788FD0A26A707, mem on start (mb), free: 248, total: 323, max: 672
2015-08-12 19:22:59,480 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA6B7FDE43B64399B76788FD0A26A707, mem on close (mb), free: 248, total: 323, max: 672
2015-08-12 19:22:59,503 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-12 19:22:59,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.215
2015-08-12 19:22:59,589 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-12 19:22:59,620 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:22:59,621 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-08-12 19:22:59,660 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:22:59,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:22:59,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:22:59,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:22:59,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:59,672 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 19:22:59,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:22:59,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:22:59,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:22:59,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-12 19:22:59,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local925233367_0030
2015-08-12 19:22:59,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:22:59,842 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:22:59,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:22:59,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:22:59,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C695A6134E184D228C2F6D6802BFB530, ordinal: 0
2015-08-12 19:22:59,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:22:59,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 19:22:59,864 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C695A6134E184D228C2F6D6802BFB530, mem on start (mb), free: 180, total: 323, max: 672
2015-08-12 19:22:59,866 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C695A6134E184D228C2F6D6802BFB530, mem on close (mb), free: 180, total: 323, max: 672
2015-08-12 19:22:59,894 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-12 19:22:59,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.222
2015-08-12 19:23:00,015 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-12 19:23:00,043 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:23:00,045 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-08-12 19:23:00,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2015-08-12 19:23:00,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:00,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:00,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2015-08-12 19:23:00,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:23:00,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 19:23:00,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2015-08-12 19:23:00,128 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2015-08-12 19:23:00,133 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2015-08-12 19:23:00,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 19:23:00,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1958870641_0031
2015-08-12 19:23:00,329 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 19:23:00,345 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 19:23:00,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:00,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:00,362 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AEC657EAEB9E4A2299CF44A08275A53D, ordinal: 0
2015-08-12 19:23:00,363 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 19:23:00,363 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 19:23:00,364 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC657EAEB9E4A2299CF44A08275A53D, mem on start (mb), free: 113, total: 323, max: 672
2015-08-12 19:23:00,367 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AEC657EAEB9E4A2299CF44A08275A53D, mem on close (mb), free: 113, total: 323, max: 672
2015-08-12 19:23:00,387 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-12 19:23:00,388 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.260
2015-08-12 19:23:00,541 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 19:23:00,586 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 19:23:00,591 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-08-12 19:23:00,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2015-08-12 19:23:00,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:00,604 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'