2015-08-12 10:56:06,923 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-12 10:56:07,013 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,014 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2015-08-12 10:56:07,141 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,155 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,163 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,170 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,174 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,180 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,185 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,186 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,192 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,199 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,205 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,206 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,208 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,211 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,213 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,214 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,220 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,221 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,228 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,238 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,247 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,257 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,267 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,268 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,275 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,280 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,282 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,283 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,284 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,286 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,291 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,292 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,298 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,299 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,306 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,310 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,313 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,317 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,325 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,330 INFO detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-12 10:56:07,606 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-12 10:56:08,471 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 10:56:08,647 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-12 10:56:08,755 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:08,768 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:08,787 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: E62C737DB3FB4F4B88A2CCBE8FA010BE
2015-08-12 10:56:09,205 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-12 10:56:09,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:09,208 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:09,208 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 10:56:09,208 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:09,209 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:09,209 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:09,215 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-12 10:56:09,855 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1829493767_0001
2015-08-12 10:56:09,865 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:09,993 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:10,037 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:10,038 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:10,185 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:10,186 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-12 10:56:10,289 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-12 10:56:10,426 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-08-12 10:56:10,460 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:10,461 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:10,503 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:10,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:10,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 10:56:10,505 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:10,506 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:10,507 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:10,509 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-12 10:56:10,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1560846655_0002
2015-08-12 10:56:10,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:10,827 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:10,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:10,840 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:10,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:10,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-12 10:56:10,881 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-12 10:56:11,001 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-12 10:56:11,039 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:11,051 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:11,103 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:11,103 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:11,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 10:56:11,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:11,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:11,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:11,118 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-12 10:56:11,641 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1666928467_0003
2015-08-12 10:56:11,641 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:11,648 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:11,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:11,663 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:11,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:11,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-12 10:56:11,694 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-12 10:56:11,779 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-12 10:56:11,812 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:11,813 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:11,866 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:11,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:11,869 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 10:56:11,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:11,871 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:11,872 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:11,874 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-12 10:56:12,081 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local461971509_0004
2015-08-12 10:56:12,082 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:12,099 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:12,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:12,107 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:12,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:12,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-12 10:56:12,145 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-12 10:56:12,228 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-12 10:56:12,246 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:12,247 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:12,265 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:12,267 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:12,269 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 10:56:12,271 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:12,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:12,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:12,276 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-12 10:56:12,412 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local2079477098_0005
2015-08-12 10:56:12,413 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:12,418 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:12,428 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:12,429 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:12,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:12,437 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-12 10:56:12,462 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-12 10:56:12,538 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-12 10:56:12,560 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:12,562 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:12,580 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:12,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:12,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 10:56:12,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:12,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:12,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:12,586 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-12 10:56:12,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1760742750_0006
2015-08-12 10:56:12,737 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:12,743 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:12,751 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:12,751 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:12,763 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:12,764 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-12 10:56:12,796 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-12 10:56:12,898 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-12 10:56:12,922 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:12,923 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:12,944 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-12 10:56:12,978 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:12,979 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:13,003 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:13,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,005 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 10:56:13,007 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:13,007 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:13,008 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:13,010 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-12 10:56:13,163 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local271285493_0007
2015-08-12 10:56:13,163 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:13,181 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:13,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:13,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:13,195 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-12 10:56:13,223 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-12 10:56:13,298 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-12 10:56:13,322 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:13,325 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:13,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:13,348 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,349 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 10:56:13,351 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:13,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:13,353 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:13,355 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-12 10:56:13,500 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local772803160_0008
2015-08-12 10:56:13,500 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:13,507 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:13,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:13,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:13,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-12 10:56:13,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-12 10:56:13,636 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-12 10:56:13,664 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:13,666 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:13,684 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:13,687 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,688 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 10:56:13,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:13,699 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:13,699 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:13,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 10:56:13,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local869699558_0009
2015-08-12 10:56:13,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:13,876 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:13,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:13,884 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:13,896 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:13,896 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-12 10:56:13,926 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-12 10:56:14,019 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-12 10:56:14,041 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,044 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:14,074 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 10:56:14,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:14,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:14,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:14,080 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 10:56:14,231 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1756570147_0010
2015-08-12 10:56:14,231 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:14,236 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:14,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:14,241 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:14,248 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,249 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-12 10:56:14,251 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,256 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,259 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,262 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1756570147_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,264 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1756570147_0010 state at FAILED
2015-08-12 10:56:14,264 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:14,266 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:14,266 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:14,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:14,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-12 10:56:14,277 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:14,278 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-12 10:56:14,278 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-08-12 10:56:14,333 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,341 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,346 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-12 10:56:14,399 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,401 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:14,421 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 10:56:14,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:14,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:14,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:14,423 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 10:56:14,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1548557053_0011
2015-08-12 10:56:14,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:14,581 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:14,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:14,588 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:14,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-12 10:56:14,597 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,599 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,600 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,602 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1548557053_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,605 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1548557053_0011 state at FAILED
2015-08-12 10:56:14,605 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:14,606 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:14,606 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:14,606 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:14,616 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-12 10:56:14,620 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:14,621 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-12 10:56:14,621 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-12 10:56:14,663 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,665 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,684 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:14,685 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 10:56:14,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:14,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:14,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:14,690 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 10:56:14,836 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local842245519_0012
2015-08-12 10:56:14,844 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:14,849 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:14,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:14,857 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:14,865 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,866 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-12 10:56:14,869 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,870 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,870 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,876 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local842245519_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:14,877 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local842245519_0012 state at FAILED
2015-08-12 10:56:14,878 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:14,879 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:14,879 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:14,880 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:14,881 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-12 10:56:14,882 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:14,883 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-12 10:56:14,883 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-12 10:56:14,918 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,919 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,925 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-12 10:56:14,963 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:14,965 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:14,986 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:14,986 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:14,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 10:56:14,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:14,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:14,987 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:14,991 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-12 10:56:15,117 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local2071883573_0013
2015-08-12 10:56:15,118 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:15,123 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:15,130 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:15,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:15,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-12 10:56:15,178 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-12 10:56:15,242 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-12 10:56:15,270 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:15,271 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:15,276 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-12 10:56:15,304 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:15,306 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:15,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:15,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 10:56:15,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:15,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:15,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:15,331 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-12 10:56:15,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local833224627_0014
2015-08-12 10:56:15,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:15,491 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:15,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:15,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:15,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,521 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-12 10:56:15,550 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-12 10:56:15,622 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-08-12 10:56:15,644 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:15,645 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 10:56:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:15,660 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:15,665 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-12 10:56:15,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local660701633_0015
2015-08-12 10:56:15,789 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:15,803 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:15,811 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:15,811 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:15,820 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,820 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-12 10:56:15,846 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-12 10:56:15,914 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-12 10:56:15,939 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:15,940 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:15,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:15,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:15,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 10:56:15,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:15,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:15,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:15,955 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-12 10:56:16,082 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local370449524_0016
2015-08-12 10:56:16,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:16,095 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:16,102 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:16,102 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:16,107 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,108 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-12 10:56:16,132 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-12 10:56:16,193 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-12 10:56:16,213 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:16,214 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:16,232 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:16,232 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 10:56:16,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:16,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:16,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:16,234 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-12 10:56:16,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local406290011_0017
2015-08-12 10:56:16,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:16,367 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:16,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:16,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:16,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,380 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-12 10:56:16,396 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-12 10:56:16,478 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-08-12 10:56:16,506 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:16,507 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:16,522 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:16,523 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,523 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 10:56:16,523 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:16,523 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:16,523 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:16,524 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-12 10:56:16,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local757107207_0018
2015-08-12 10:56:16,647 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:16,668 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:16,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:16,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:16,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-12 10:56:16,717 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-12 10:56:16,839 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-12 10:56:16,876 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:16,877 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:16,882 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-12 10:56:16,911 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:16,912 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:16,925 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:16,925 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:16,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 10:56:16,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:16,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:16,930 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:16,933 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-12 10:56:17,057 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local744783482_0019
2015-08-12 10:56:17,058 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:17,074 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:17,082 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:17,083 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:17,088 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,089 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-12 10:56:17,114 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-12 10:56:17,180 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-12 10:56:17,205 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:17,206 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:17,216 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:17,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,217 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 10:56:17,218 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:17,218 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:17,218 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:17,219 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-12 10:56:17,341 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1674202618_0020
2015-08-12 10:56:17,342 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:17,359 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:17,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:17,365 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:17,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-12 10:56:17,399 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-12 10:56:17,462 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-12 10:56:17,492 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:17,493 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:17,504 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:17,505 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 10:56:17,666 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local2069141125_0021
2015-08-12 10:56:17,666 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:17,684 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:17,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:17,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:17,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-12 10:56:17,703 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:17,715 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:17,724 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:17,735 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2069141125_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:17,743 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local2069141125_0021 state at FAILED
2015-08-12 10:56:17,743 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:17,743 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:17,743 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:17,748 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:17,749 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-12 10:56:17,749 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:17,749 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-12 10:56:17,750 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-08-12 10:56:17,812 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:17,813 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:17,820 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-12 10:56:17,841 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:17,844 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:17,861 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:17,863 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:17,865 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 10:56:17,867 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:17,868 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:17,870 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:17,871 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 10:56:18,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1633956399_0022
2015-08-12 10:56:18,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:18,011 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:18,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:18,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:18,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,021 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-12 10:56:18,023 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,023 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,023 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,027 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1633956399_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,030 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1633956399_0022 state at FAILED
2015-08-12 10:56:18,030 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:18,030 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:18,030 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:18,031 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:18,032 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-12 10:56:18,032 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:18,033 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-12 10:56:18,033 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-12 10:56:18,084 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,085 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:18,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 10:56:18,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:18,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:18,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:18,100 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 10:56:18,223 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1171220150_0023
2015-08-12 10:56:18,227 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:18,244 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:18,250 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:18,250 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:18,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,256 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-12 10:56:18,257 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,258 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,258 ERROR stream.SourceStage (SourceStage.java:map(110)) - 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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,260 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1171220150_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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
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.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
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 10:56:18,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1171220150_0023 state at FAILED
2015-08-12 10:56:18,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-08-12 10:56:18,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-08-12 10:56:18,269 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-08-12 10:56:18,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-08-12 10:56:18,273 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-12 10:56:18,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-08-12 10:56:18,274 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-12 10:56:18,274 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-08-12 10:56:18,322 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,322 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,332 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:18,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 10:56:18,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:18,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:18,340 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:18,342 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-12 10:56:18,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1358333731_0024
2015-08-12 10:56:18,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:18,476 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:18,484 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:18,484 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:18,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,490 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-12 10:56:18,510 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-12 10:56:18,572 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-08-12 10:56:18,591 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,592 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,597 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-12 10:56:18,629 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,630 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,639 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:18,640 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 10:56:18,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:18,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:18,644 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:18,645 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-12 10:56:18,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local298932933_0025
2015-08-12 10:56:18,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:18,780 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:18,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:18,784 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:18,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,790 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-12 10:56:18,811 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-12 10:56:18,879 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-12 10:56:18,896 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,897 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,901 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-08-12 10:56:18,926 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:18,928 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:18,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:18,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:18,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 10:56:18,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:18,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:18,939 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:18,941 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-12 10:56:19,069 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local2072160091_0026
2015-08-12 10:56:19,070 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:19,085 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:19,092 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:19,093 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:19,099 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,100 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-12 10:56:19,127 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-12 10:56:19,193 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-12 10:56:19,223 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:19,224 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:19,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:19,235 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 10:56:19,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:19,238 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:19,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:19,244 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-12 10:56:19,376 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1851585311_0027
2015-08-12 10:56:19,387 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:19,392 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:19,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:19,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:19,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,411 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-12 10:56:19,434 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-12 10:56:19,499 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-12 10:56:19,521 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:19,525 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:19,549 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:19,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 10:56:19,555 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:19,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:19,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:19,579 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-12 10:56:19,718 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local440026072_0028
2015-08-12 10:56:19,719 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:19,724 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:19,729 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:19,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:19,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-12 10:56:19,755 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-12 10:56:19,841 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-12 10:56:19,865 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:19,866 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:19,874 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:19,875 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:19,876 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 10:56:19,877 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:19,877 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:19,878 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:19,880 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-12 10:56:19,998 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1785445217_0029
2015-08-12 10:56:20,007 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:20,012 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:20,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:20,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:20,022 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:20,024 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-12 10:56:20,049 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-12 10:56:20,119 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-12 10:56:20,145 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:20,146 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:20,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:20,157 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:20,159 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 10:56:20,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:20,161 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:20,162 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:20,164 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-12 10:56:20,272 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local416405639_0030
2015-08-12 10:56:20,281 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:20,286 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:20,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:20,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:20,300 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:20,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-12 10:56:20,316 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-12 10:56:20,386 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-12 10:56:20,413 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:20,414 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:20,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-08-12 10:56:20,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:20,425 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 10:56:20,426 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] parallel execution is enabled: false
2015-08-12 10:56:20,427 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting jobs: 1
2015-08-12 10:56:20,428 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] allocating threads: 1
2015-08-12 10:56:20,431 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 10:56:20,555 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local789636235_0031
2015-08-12 10:56:20,565 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-08-12 10:56:20,571 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt
2015-08-12 10:56:20,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-12 10:56:20,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-12 10:56:20,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 10:56:20,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-12 10:56:20,601 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-12 10:56:20,659 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-12 10:56:20,681 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 10:56:20,682 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 10:56:20,688 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'