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'