Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

0

ignored

16.524s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.845s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.750s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 3.701s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.424s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.431s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.082s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.102s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.425s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.418s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.086s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.432s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.411s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.388s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.066s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.407s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.306s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.329s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.407s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.375s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.378s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.604s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.033s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.347s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.057s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.305s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.043s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.343s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.355s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.344s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.079s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.263s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.281s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.269s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.421s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.457s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.355s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.357s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.346s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.048s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.454s passed

Standard output

2015-08-12 19:23:02,514 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 19:23:02,611 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EveryEveryPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2015-08-12 19:23:03,395 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 19:23:04,464 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:23:04,790 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-08-12 19:23:04,992 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:05,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:23:05,277 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4F561F28BB3E4087808C7FAA8FDC4729
2015-08-12 19:23:05,494 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.109
2015-08-12 19:23:05,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:05,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:05,743 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 19:23:05,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:05,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:05,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 19:23:05,755 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:05,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:05,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:05,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-12 19:23:06,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1611904871_0001
2015-08-12 19:23:06,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:06,688 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:06,718 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:06,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:06,731 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E09396C5F0444B5CB41004D7AB094BA8, ordinal: 0
2015-08-12 19:23:06,803 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:06,803 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 19:23:06,805 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E09396C5F0444B5CB41004D7AB094BA8, mem on start (mb), free: 112, total: 210, max: 672
2015-08-12 19:23:06,820 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E09396C5F0444B5CB41004D7AB094BA8, mem on close (mb), free: 110, total: 210, max: 672
2015-08-12 19:23:06,912 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-12 19:23:06,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:01.161
2015-08-12 19:23:07,093 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2015-08-12 19:23:07,165 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:07,167 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:07,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.138
2015-08-12 19:23:07,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:07,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:07,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:07,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:07,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 19:23:07,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:07,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:07,354 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:07,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-12 19:23:07,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1829833634_0002
2015-08-12 19:23:07,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:07,638 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:07,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:07,653 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:07,669 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F8E8AB634DBB46CE97F0E4BA67F9A805, ordinal: 0
2015-08-12 19:23:07,670 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:07,671 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 19:23:07,672 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8E8AB634DBB46CE97F0E4BA67F9A805, mem on start (mb), free: 156, total: 210, max: 672
2015-08-12 19:23:07,674 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F8E8AB634DBB46CE97F0E4BA67F9A805, mem on close (mb), free: 156, total: 210, max: 672
2015-08-12 19:23:07,703 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-12 19:23:07,704 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.350
2015-08-12 19:23:07,844 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-12 19:23:07,909 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:07,911 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:08,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.103
2015-08-12 19:23:08,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:08,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:08,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:08,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:08,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 19:23:08,088 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:08,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:08,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:08,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-12 19:23:08,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1224212263_0003
2015-08-12 19:23:08,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:08,476 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:08,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:08,484 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:08,500 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E96F5AF203F441C09E9D40A585754387, ordinal: 0
2015-08-12 19:23:08,502 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:08,502 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 19:23:08,503 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E96F5AF203F441C09E9D40A585754387, mem on start (mb), free: 88, total: 210, max: 672
2015-08-12 19:23:08,510 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E96F5AF203F441C09E9D40A585754387, mem on close (mb), free: 88, total: 210, max: 672
2015-08-12 19:23:08,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-12 19:23:08,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.451
2015-08-12 19:23:08,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-12 19:23:08,714 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:08,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:23:08,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-08-12 19:23:08,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:08,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:08,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:08,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:08,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 19:23:08,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:08,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:08,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:08,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-12 19:23:08,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2005472059_0004
2015-08-12 19:23:08,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:08,975 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:08,981 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:08,981 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:08,992 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BDBE3D73945A4550943B3458C81F1725, ordinal: 0
2015-08-12 19:23:08,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:23:08,994 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 19:23:08,994 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDBE3D73945A4550943B3458C81F1725, mem on start (mb), free: 248, total: 323, max: 672
2015-08-12 19:23:08,999 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BDBE3D73945A4550943B3458C81F1725, mem on close (mb), free: 248, total: 323, max: 672
2015-08-12 19:23:09,026 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-12 19:23:09,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.233
2015-08-12 19:23:09,121 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-12 19:23:09,141 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:09,142 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:09,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-08-12 19:23:09,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:09,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:09,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:09,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:09,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 19:23:09,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:09,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:09,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:09,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-12 19:23:09,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1146563256_0005
2015-08-12 19:23:09,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:09,400 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:09,411 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:09,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:09,422 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5B94100B2D54688A3502AD4E1DB4F38, ordinal: 0
2015-08-12 19:23:09,424 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:09,425 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 19:23:09,425 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5B94100B2D54688A3502AD4E1DB4F38, mem on start (mb), free: 174, total: 323, max: 672
2015-08-12 19:23:09,432 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5B94100B2D54688A3502AD4E1DB4F38, mem on close (mb), free: 174, total: 323, max: 672
2015-08-12 19:23:09,449 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-12 19:23:09,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.234
2015-08-12 19:23:09,545 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-12 19:23:09,571 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:09,572 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:09,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2015-08-12 19:23:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:09,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:09,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:09,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 19:23:09,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:09,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:09,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:09,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-12 19:23:09,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1565265488_0006
2015-08-12 19:23:09,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:09,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:23:09,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:09,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:09,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E69D58BAEF0B47F987C060B781A43889, ordinal: 0
2015-08-12 19:23:09,857 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:09,858 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 19:23:09,858 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E69D58BAEF0B47F987C060B781A43889, mem on start (mb), free: 99, total: 323, max: 672
2015-08-12 19:23:09,862 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E69D58BAEF0B47F987C060B781A43889, mem on close (mb), free: 99, total: 323, max: 672
2015-08-12 19:23:09,893 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-12 19:23:09,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.226
2015-08-12 19:23:09,977 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-12 19:23:10,045 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:10,046 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:10,064 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2015-08-12 19:23:10,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:10,065 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-12 19:23:10,093 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:10,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:23:10,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 19:23:10,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:10,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:10,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:10,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:10,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 19:23:10,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:10,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:10,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:10,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-12 19:23:10,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1359020371_0007
2015-08-12 19:23:10,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:10,338 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:10,345 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:10,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:10,353 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A81CD2BFF7844FC0905BB45C76AA5E6B, ordinal: 0
2015-08-12 19:23:10,354 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:10,355 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 19:23:10,355 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A81CD2BFF7844FC0905BB45C76AA5E6B, mem on start (mb), free: 235, total: 318, max: 672
2015-08-12 19:23:10,358 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A81CD2BFF7844FC0905BB45C76AA5E6B, mem on close (mb), free: 235, total: 318, max: 672
2015-08-12 19:23:10,381 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-12 19:23:10,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.203
2015-08-12 19:23:10,479 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-12 19:23:10,539 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:10,540 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:10,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-08-12 19:23:10,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:10,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:10,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:10,600 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:10,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 19:23:10,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:10,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:10,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:10,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-12 19:23:10,736 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local901001724_0008
2015-08-12 19:23:10,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:10,745 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:10,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:10,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:10,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5247AE630EC43B39D2B91DE29AF5E26, ordinal: 0
2015-08-12 19:23:10,763 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:10,764 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 19:23:10,764 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5247AE630EC43B39D2B91DE29AF5E26, mem on start (mb), free: 152, total: 318, max: 672
2015-08-12 19:23:10,767 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5247AE630EC43B39D2B91DE29AF5E26, mem on close (mb), free: 152, total: 318, max: 672
2015-08-12 19:23:10,796 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-12 19:23:10,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.197
2015-08-12 19:23:10,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-12 19:23:10,899 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:10,901 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:10,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 19:23:10,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:10,961 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:10,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:10,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:10,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 19:23:10,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:10,979 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:10,979 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:10,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 19:23:11,133 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local272070855_0009
2015-08-12 19:23:11,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:11,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:23:11,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:11,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:11,183 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F58AA20F1B2840A6A6DFF065B8269D7B, ordinal: 0
2015-08-12 19:23:11,185 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:11,186 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 19:23:11,187 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F58AA20F1B2840A6A6DFF065B8269D7B, mem on start (mb), free: 303, total: 322, max: 672
2015-08-12 19:23:11,192 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F58AA20F1B2840A6A6DFF065B8269D7B, mem on close (mb), free: 303, total: 322, max: 672
2015-08-12 19:23:11,213 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-12 19:23:11,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.235
2015-08-12 19:23:11,283 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 19:23:11,314 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:11,315 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:11,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 19:23:11,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:11,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:11,394 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:11,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:11,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 19:23:11,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:11,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:11,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:11,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 19:23:11,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local413842834_0010
2015-08-12 19:23:11,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:11,608 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:11,619 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:11,621 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:11,633 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F9EE10EA96A0472DB41A1144306409C4, ordinal: 0
2015-08-12 19:23:11,635 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:11,637 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 19:23:11,638 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9EE10EA96A0472DB41A1144306409C4, mem on start (mb), free: 227, total: 322, max: 672
2015-08-12 19:23:11,644 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:23:11,648 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:23:11,649 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:23:11,654 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9EE10EA96A0472DB41A1144306409C4, mem on close (mb), free: 227, total: 322, max: 672
2015-08-12 19:23:11,663 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local413842834_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:23:11,671 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local413842834_0010 state at FAILED
2015-08-12 19:23:11,671 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:11,674 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:11,674 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:11,675 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:11,676 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 19:23:11,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:11,686 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-12 19:23:11,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.292
2015-08-12 19:23:11,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2015-08-12 19:23:11,716 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:11,717 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:11,756 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.033
2015-08-12 19:23:11,757 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:11,757 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-12 19:23:11,785 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:11,788 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:11,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-08-12 19:23:11,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:11,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:11,852 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:11,852 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 19:23:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:11,853 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:11,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 19:23:12,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1349608695_0011
2015-08-12 19:23:12,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:12,046 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:12,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:12,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:12,061 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1350370C87A43F390160F590FB45056, ordinal: 0
2015-08-12 19:23:12,063 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:12,065 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 19:23:12,066 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1350370C87A43F390160F590FB45056, mem on start (mb), free: 163, total: 322, max: 672
2015-08-12 19:23:12,068 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:23:12,076 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:23:12,076 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:23:12,078 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1350370C87A43F390160F590FB45056, mem on close (mb), free: 163, total: 322, max: 672
2015-08-12 19:23:12,080 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1349608695_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:23:12,084 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1349608695_0011 state at FAILED
2015-08-12 19:23:12,084 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:12,084 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:12,084 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:12,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:12,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 19:23:12,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:12,086 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-12 19:23:12,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.233
2015-08-12 19:23:12,087 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-12 19:23:12,136 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:12,139 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:12,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-08-12 19:23:12,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:12,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:12,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:12,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:12,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 19:23:12,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:12,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:12,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:12,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 19:23:12,339 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local879901926_0012
2015-08-12 19:23:12,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:12,346 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:12,352 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:12,352 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:12,362 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C48EEEA9D7844CD5A6FBD6074FE2F5A0, ordinal: 0
2015-08-12 19:23:12,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:12,364 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 19:23:12,364 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C48EEEA9D7844CD5A6FBD6074FE2F5A0, mem on start (mb), free: 104, total: 322, max: 672
2015-08-12 19:23:12,366 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:23:12,367 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:23:12,376 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:23:12,380 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C48EEEA9D7844CD5A6FBD6074FE2F5A0, mem on close (mb), free: 104, total: 322, max: 672
2015-08-12 19:23:12,382 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local879901926_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:23:12,384 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local879901926_0012 state at FAILED
2015-08-12 19:23:12,385 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:12,385 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:12,385 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:12,385 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:12,385 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 19:23:12,391 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:12,392 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-12 19:23:12,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.206
2015-08-12 19:23:12,393 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-12 19:23:12,457 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:12,459 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:12,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2015-08-12 19:23:12,475 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:12,475 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-12 19:23:12,504 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:12,505 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:12,546 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 19:23:12,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:12,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:12,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:12,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:12,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 19:23:12,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:12,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:12,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:12,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-12 19:23:12,737 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1901944757_0013
2015-08-12 19:23:12,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:12,744 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:12,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:12,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:12,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA8A3301A0954C8DB242D5E78F3FC780, ordinal: 0
2015-08-12 19:23:12,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:23:12,763 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 19:23:12,763 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA8A3301A0954C8DB242D5E78F3FC780, mem on start (mb), free: 267, total: 322, max: 672
2015-08-12 19:23:12,767 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA8A3301A0954C8DB242D5E78F3FC780, mem on close (mb), free: 267, total: 322, max: 672
2015-08-12 19:23:12,789 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-12 19:23:12,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.213
2015-08-12 19:23:12,901 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-12 19:23:12,957 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:12,963 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:12,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.020
2015-08-12 19:23:13,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:13,004 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-12 19:23:13,048 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:13,049 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:13,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-08-12 19:23:13,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:13,076 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:13,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:13,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:13,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 19:23:13,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:13,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:13,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:13,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-12 19:23:13,244 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local10111260_0014
2015-08-12 19:23:13,245 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:13,251 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:13,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:13,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:13,266 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A01DF69DC0EE4BE68120FF6859227703, ordinal: 0
2015-08-12 19:23:13,268 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:13,270 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 19:23:13,272 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A01DF69DC0EE4BE68120FF6859227703, mem on start (mb), free: 185, total: 322, max: 672
2015-08-12 19:23:13,275 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A01DF69DC0EE4BE68120FF6859227703, mem on close (mb), free: 185, total: 322, max: 672
2015-08-12 19:23:13,305 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-12 19:23:13,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.210
2015-08-12 19:23:13,379 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2015-08-12 19:23:13,404 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:13,405 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:13,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2015-08-12 19:23:13,466 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:13,486 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:13,487 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:13,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 19:23:13,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:13,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:13,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:13,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-12 19:23:13,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local657676327_0015
2015-08-12 19:23:13,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:13,653 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:13,660 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:13,660 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:13,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DDCA93FE07854FC7A40CE335082088B9, ordinal: 0
2015-08-12 19:23:13,667 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:13,667 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 19:23:13,668 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDCA93FE07854FC7A40CE335082088B9, mem on start (mb), free: 110, total: 322, max: 672
2015-08-12 19:23:13,673 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDCA93FE07854FC7A40CE335082088B9, mem on close (mb), free: 110, total: 322, max: 672
2015-08-12 19:23:13,694 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-12 19:23:13,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.207
2015-08-12 19:23:13,786 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-12 19:23:13,814 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:13,815 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:13,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-08-12 19:23:13,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:13,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:13,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:13,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:13,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 19:23:13,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:13,897 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:13,898 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:13,906 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-12 19:23:14,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local740848353_0016
2015-08-12 19:23:14,128 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:14,137 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:14,144 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:14,144 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:14,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1AF565EF1BE4B94A6453B709D7DEADF, ordinal: 0
2015-08-12 19:23:14,153 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:14,153 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 19:23:14,153 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1AF565EF1BE4B94A6453B709D7DEADF, mem on start (mb), free: 269, total: 322, max: 672
2015-08-12 19:23:14,157 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1AF565EF1BE4B94A6453B709D7DEADF, mem on close (mb), free: 269, total: 322, max: 672
2015-08-12 19:23:14,320 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-12 19:23:14,321 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.425
2015-08-12 19:23:14,389 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-12 19:23:14,416 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:14,419 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:14,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-08-12 19:23:14,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:14,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:14,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:14,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:14,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 19:23:14,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:14,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:14,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:14,474 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-12 19:23:14,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local418101552_0017
2015-08-12 19:23:14,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:14,657 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:14,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:14,664 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:14,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5F65F7F0A6F4BD4A594008D779A8419, ordinal: 0
2015-08-12 19:23:14,671 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:14,671 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 19:23:14,671 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5F65F7F0A6F4BD4A594008D779A8419, mem on start (mb), free: 196, total: 322, max: 672
2015-08-12 19:23:14,675 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5F65F7F0A6F4BD4A594008D779A8419, mem on close (mb), free: 196, total: 322, max: 672
2015-08-12 19:23:14,698 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-12 19:23:14,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.226
2015-08-12 19:23:14,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2015-08-12 19:23:14,793 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:14,793 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:14,826 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-08-12 19:23:14,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:14,827 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:14,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:14,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:14,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 19:23:14,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:14,844 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:14,845 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:14,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-12 19:23:14,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1926355443_0018
2015-08-12 19:23:14,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:15,007 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:15,014 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:15,014 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:15,021 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AFF80FC24A4A4088A26C592FC0937615, ordinal: 0
2015-08-12 19:23:15,022 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:15,022 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 19:23:15,022 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFF80FC24A4A4088A26C592FC0937615, mem on start (mb), free: 126, total: 322, max: 672
2015-08-12 19:23:15,028 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AFF80FC24A4A4088A26C592FC0937615, mem on close (mb), free: 126, total: 322, max: 672
2015-08-12 19:23:15,045 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-12 19:23:15,046 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.206
2015-08-12 19:23:15,111 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-12 19:23:15,141 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:15,142 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:15,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2015-08-12 19:23:15,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:15,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-12 19:23:15,180 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:15,181 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:15,204 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-08-12 19:23:15,205 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:15,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:15,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:15,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:15,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 19:23:15,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:15,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:15,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:15,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-12 19:23:15,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local240693816_0019
2015-08-12 19:23:15,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:15,369 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:15,376 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:15,377 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:15,382 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B443483A8AEE4CEB98BCBA209C3BA08A, ordinal: 0
2015-08-12 19:23:15,383 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:15,384 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 19:23:15,384 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B443483A8AEE4CEB98BCBA209C3BA08A, mem on start (mb), free: 282, total: 323, max: 672
2015-08-12 19:23:15,387 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B443483A8AEE4CEB98BCBA209C3BA08A, mem on close (mb), free: 282, total: 323, max: 672
2015-08-12 19:23:15,419 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-12 19:23:15,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.203
2015-08-12 19:23:15,498 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-12 19:23:15,518 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:15,519 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:15,550 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-08-12 19:23:15,552 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:15,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:15,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 19:23:15,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:15,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:15,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:15,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-12 19:23:15,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local487798934_0020
2015-08-12 19:23:15,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:15,734 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:15,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:15,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:15,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB1AF2DACAAF4AFBB0691A2AA55F881C, ordinal: 0
2015-08-12 19:23:15,749 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:15,750 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 19:23:15,750 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1AF2DACAAF4AFBB0691A2AA55F881C, mem on start (mb), free: 211, total: 323, max: 672
2015-08-12 19:23:15,754 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1AF2DACAAF4AFBB0691A2AA55F881C, mem on close (mb), free: 211, total: 323, max: 672
2015-08-12 19:23:15,776 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-12 19:23:15,777 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.208
2015-08-12 19:23:15,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-12 19:23:15,885 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:15,886 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:15,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-08-12 19:23:15,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:15,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:15,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:15,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:15,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 19:23:15,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:15,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:15,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:15,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 19:23:16,062 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local16316626_0021
2015-08-12 19:23:16,062 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:16,071 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:16,076 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:16,077 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:16,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EE3E59AC534940439E70B168F3496495, ordinal: 0
2015-08-12 19:23:16,085 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:16,086 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 19:23:16,086 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE3E59AC534940439E70B168F3496495, mem on start (mb), free: 140, total: 323, max: 672
2015-08-12 19:23:16,088 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:23:16,095 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:23:16,097 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:23:16,099 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EE3E59AC534940439E70B168F3496495, mem on close (mb), free: 139, total: 323, max: 672
2015-08-12 19:23:16,100 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local16316626_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:23:16,107 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local16316626_0021 state at FAILED
2015-08-12 19:23:16,108 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:16,108 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:16,109 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:16,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:16,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 19:23:16,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:16,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutting down job executor
2015-08-12 19:23:16,115 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] shutdown complete
2015-08-12 19:23:16,115 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-12 19:23:16,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.178
2015-08-12 19:23:16,116 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2015-08-12 19:23:16,178 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:16,180 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:16,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2015-08-12 19:23:16,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:16,195 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-12 19:23:16,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:23:16,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:23:16,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-08-12 19:23:16,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:16,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:16,263 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:16,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:16,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 19:23:16,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:16,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 19:23:16,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local858129058_0022
2015-08-12 19:23:16,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:16,397 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:16,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:16,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:16,415 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA1122B9AAD34EC29ADE42D466BDD805, ordinal: 0
2015-08-12 19:23:16,416 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:16,417 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 19:23:16,418 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1122B9AAD34EC29ADE42D466BDD805, mem on start (mb), free: 77, total: 323, max: 672
2015-08-12 19:23:16,421 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:23:16,437 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:23:16,443 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:23:16,449 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1122B9AAD34EC29ADE42D466BDD805, mem on close (mb), free: 76, total: 323, max: 672
2015-08-12 19:23:16,451 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local858129058_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:23:16,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local858129058_0022 state at FAILED
2015-08-12 19:23:16,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:16,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:16,456 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:16,457 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:16,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 19:23:16,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:16,459 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-12 19:23:16,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.196
2015-08-12 19:23:16,464 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-12 19:23:16,518 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:16,519 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:16,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 19:23:16,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:16,555 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:16,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:16,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:16,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 19:23:16,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:16,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:16,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:16,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 19:23:16,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1470038606_0023
2015-08-12 19:23:16,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:16,707 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:16,713 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:16,714 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:16,718 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DDFC9040ADED40B5A1B478A3445C5EBC, ordinal: 0
2015-08-12 19:23:16,719 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:16,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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 19:23:16,720 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDFC9040ADED40B5A1B478A3445C5EBC, mem on start (mb), free: 238, total: 308, max: 672
2015-08-12 19:23:16,720 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:23:16,722 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:23:16,723 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:23:16,737 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDFC9040ADED40B5A1B478A3445C5EBC, mem on close (mb), free: 237, total: 308, max: 672
2015-08-12 19:23:16,740 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1470038606_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:23:16,743 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] hadoop job job_local1470038606_0023 state at FAILED
2015-08-12 19:23:16,743 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] failure info: NA
2015-08-12 19:23:16,743 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events identify failed tasks
2015-08-12 19:23:16,743 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [every.every] task completion events count: 0
2015-08-12 19:23:16,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping all jobs
2015-08-12 19:23:16,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 19:23:16,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] stopped all jobs
2015-08-12 19:23:16,744 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-12 19:23:16,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.176
2015-08-12 19:23:16,745 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2015-08-12 19:23:16,777 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:16,778 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:16,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-08-12 19:23:16,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:16,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:16,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:16,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:16,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 19:23:16,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:16,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:16,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:16,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-12 19:23:16,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2059915169_0024
2015-08-12 19:23:16,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:16,959 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:16,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:16,969 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:16,978 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD1EEDE17E6547238D905017B6FE8DB9, ordinal: 0
2015-08-12 19:23:16,980 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:16,980 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 19:23:16,981 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD1EEDE17E6547238D905017B6FE8DB9, mem on start (mb), free: 183, total: 308, max: 672
2015-08-12 19:23:16,985 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD1EEDE17E6547238D905017B6FE8DB9, mem on close (mb), free: 183, total: 308, max: 672
2015-08-12 19:23:17,005 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-12 19:23:17,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.190
2015-08-12 19:23:17,093 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2015-08-12 19:23:17,113 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:17,114 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:17,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2015-08-12 19:23:17,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:17,125 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-12 19:23:17,150 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:17,151 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:17,175 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-08-12 19:23:17,175 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:17,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:17,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:17,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:17,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 19:23:17,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:17,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:17,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:17,197 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-12 19:23:17,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1328245422_0025
2015-08-12 19:23:17,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:17,320 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:17,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:17,328 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:17,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C011FB124D6C44E192E3B7890DED7FDD, ordinal: 0
2015-08-12 19:23:17,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:23:17,335 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 19:23:17,335 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C011FB124D6C44E192E3B7890DED7FDD, mem on start (mb), free: 107, total: 308, max: 672
2015-08-12 19:23:17,338 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C011FB124D6C44E192E3B7890DED7FDD, mem on close (mb), free: 107, total: 308, max: 672
2015-08-12 19:23:17,362 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-12 19:23:17,362 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.175
2015-08-12 19:23:17,430 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-12 19:23:17,453 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:17,454 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:17,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2015-08-12 19:23:17,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:17,483 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2015-08-12 19:23:17,512 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:17,513 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:17,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-08-12 19:23:17,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:17,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:17,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:17,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:17,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 19:23:17,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:17,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:17,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:17,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-12 19:23:17,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2005785943_0026
2015-08-12 19:23:17,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:17,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:23:17,750 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:17,751 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:17,755 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A6292E93DE6D4BF9B769503D08455A73, ordinal: 0
2015-08-12 19:23:17,756 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:17,756 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 19:23:17,757 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6292E93DE6D4BF9B769503D08455A73, mem on start (mb), free: 243, total: 298, max: 672
2015-08-12 19:23:17,760 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A6292E93DE6D4BF9B769503D08455A73, mem on close (mb), free: 243, total: 298, max: 672
2015-08-12 19:23:17,772 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-12 19:23:17,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.208
2015-08-12 19:23:17,843 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-12 19:23:17,869 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:17,871 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:17,898 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-08-12 19:23:17,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:17,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:17,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:17,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:17,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 19:23:17,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:17,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:17,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:17,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-12 19:23:18,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1456020431_0027
2015-08-12 19:23:18,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:18,110 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:18,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:18,115 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:18,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6EE38BD8FA64627B80FD42BF3A6DF38, ordinal: 0
2015-08-12 19:23:18,122 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:18,123 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 19:23:18,123 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6EE38BD8FA64627B80FD42BF3A6DF38, mem on start (mb), free: 172, total: 298, max: 672
2015-08-12 19:23:18,127 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6EE38BD8FA64627B80FD42BF3A6DF38, mem on close (mb), free: 172, total: 298, max: 672
2015-08-12 19:23:18,143 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-12 19:23:18,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.223
2015-08-12 19:23:18,300 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-12 19:23:18,323 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:18,325 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:18,382 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-08-12 19:23:18,388 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:18,389 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:18,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:18,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:18,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 19:23:18,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:18,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:18,435 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:18,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-12 19:23:18,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1550520190_0028
2015-08-12 19:23:18,615 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:18,621 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:18,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:18,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:18,632 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DDB9EA1DCB5C4C5B8B5910A7ED604698, ordinal: 0
2015-08-12 19:23:18,633 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:18,633 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 19:23:18,634 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDB9EA1DCB5C4C5B8B5910A7ED604698, mem on start (mb), free: 102, total: 298, max: 672
2015-08-12 19:23:18,637 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DDB9EA1DCB5C4C5B8B5910A7ED604698, mem on close (mb), free: 102, total: 298, max: 672
2015-08-12 19:23:18,649 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-12 19:23:18,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.225
2015-08-12 19:23:18,721 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-12 19:23:18,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:23:18,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:23:18,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-08-12 19:23:18,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:18,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:18,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:18,791 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:18,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 19:23:18,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:18,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:18,797 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:18,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-12 19:23:18,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local1452338744_0029
2015-08-12 19:23:18,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:18,965 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:18,973 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:18,973 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:18,979 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CAF7E13A918845789151C3C4FAEB2C41, ordinal: 0
2015-08-12 19:23:18,980 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:18,980 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 19:23:18,981 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CAF7E13A918845789151C3C4FAEB2C41, mem on start (mb), free: 238, total: 289, max: 672
2015-08-12 19:23:18,984 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CAF7E13A918845789151C3C4FAEB2C41, mem on close (mb), free: 238, total: 289, max: 672
2015-08-12 19:23:18,996 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-12 19:23:18,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.205
2015-08-12 19:23:19,067 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-12 19:23:19,105 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:19,107 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:19,129 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-08-12 19:23:19,130 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:19,131 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:19,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:19,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:19,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 19:23:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:19,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:19,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-12 19:23:19,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local2001501358_0030
2015-08-12 19:23:19,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:19,299 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:19,306 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:19,306 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:19,310 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E80C6DB68DF1475FBB5717C7B99A5B13, ordinal: 0
2015-08-12 19:23:19,311 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:19,311 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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 19:23:19,311 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E80C6DB68DF1475FBB5717C7B99A5B13, mem on start (mb), free: 173, total: 289, max: 672
2015-08-12 19:23:19,314 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E80C6DB68DF1475FBB5717C7B99A5B13, mem on close (mb), free: 173, total: 289, max: 672
2015-08-12 19:23:19,330 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-12 19:23:19,332 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.184
2015-08-12 19:23:19,425 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-12 19:23:19,452 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:19,453 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:19,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-08-12 19:23:19,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 19:23:19,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 19:23:19,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting
2015-08-12 19:23:19,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  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:19,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 19:23:19,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  parallel execution of steps is enabled: false
2015-08-12 19:23:19,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  executing total steps: 1
2015-08-12 19:23:19,507 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  allocating management threads: 1
2015-08-12 19:23:19,508 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 19:23:19,715 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] submitted hadoop job: job_local9417151_0031
2015-08-12 19:23:19,715 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] tracking url: http://localhost:8080/
2015-08-12 19:23:19,722 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:19,727 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 19:23:19,727 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 19:23:19,741 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC460B563F3045E3B4FB9D20019C829B, ordinal: 0
2015-08-12 19:23:19,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:23:19,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/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 19:23:19,743 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC460B563F3045E3B4FB9D20019C829B, mem on start (mb), free: 110, total: 289, max: 672
2015-08-12 19:23:19,747 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC460B563F3045E3B4FB9D20019C829B, mem on close (mb), free: 110, total: 289, max: 672
2015-08-12 19:23:19,773 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-12 19:23:19,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every]  completed in: 00:00.266
2015-08-12 19:23:19,878 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 19:23:19,910 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:19,910 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:19,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2015-08-12 19:23:19,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [every.every] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-08-12 19:23:19,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'