Class cascading.detail.EachEachPipeAssemblyPlatformTest

40

tests

0

failures

0

ignored

8.734s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.404s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.302s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 1.710s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.298s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.309s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.021s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.017s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.224s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.257s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.018s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.298s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.223s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.272s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.022s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.227s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.174s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.169s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.231s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.231s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.215s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.232s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.018s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.212s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.014s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.206s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.014s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.233s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.214s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.213s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.016s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.160s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.160s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.150s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.211s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.210s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.210s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.208s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.208s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.013s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.210s passed

Standard output

2015-07-17 15:15:57,194 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:15:57,213 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,213 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2015-07-17 15:15:57,285 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,295 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,301 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,307 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,312 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,316 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,319 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,320 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,323 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,326 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,328 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,328 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,329 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,330 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,331 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,331 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,334 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,335 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,338 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,344 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,349 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,352 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,354 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,355 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,357 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,359 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,359 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,360 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,360 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,361 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,363 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,364 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,366 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,366 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,368 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,371 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,373 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,375 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,378 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,380 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-07-17 15:15:57,545 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-07-17 15:15:58,058 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-17 15:15:58,169 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 15:15:58,252 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:15:58,253 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:15:58,264 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 32F0427BB9BA49ECB0A529A6ADACB613
2015-07-17 15:15:58,441 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:15:58,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:15:58,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:58,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-07-17 15:15:58,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:15:58,444 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:15:58,444 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:15:58,445 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-07-17 15:15:58,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local515955909_0001
2015-07-17 15:15:58,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:15:59,059 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:15:59,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:15:59,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:15:59,118 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-07-17 15:15:59,175 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-07-17 15:15:59,254 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-07-17 15:15:59,271 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:15:59,272 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:15:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:15:59,291 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-07-17 15:15:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:15:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:15:59,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:15:59,292 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-07-17 15:15:59,440 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local229455301_0002
2015-07-17 15:15:59,440 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:15:59,445 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:15:59,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:15:59,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:15:59,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-07-17 15:15:59,487 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-07-17 15:15:59,558 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-07-17 15:15:59,580 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:15:59,581 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:15:59,605 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:15:59,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-07-17 15:15:59,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:15:59,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:15:59,606 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:15:59,608 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-07-17 15:15:59,839 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1764443830_0003
2015-07-17 15:15:59,839 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:15:59,843 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:15:59,855 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:15:59,855 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:15:59,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-07-17 15:15:59,888 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-07-17 15:15:59,961 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-07-17 15:15:59,976 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:15:59,977 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:15:59,998 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:15:59,998 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:15:59,998 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-07-17 15:15:59,998 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:15:59,999 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:15:59,999 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:15:59,999 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-07-17 15:16:00,160 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1516151113_0004
2015-07-17 15:16:00,160 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:00,164 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:00,176 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:00,176 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:00,181 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,182 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-07-17 15:16:00,212 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-07-17 15:16:00,271 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-07-17 15:16:00,287 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:00,287 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:00,304 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:00,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-07-17 15:16:00,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:00,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:00,305 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:00,306 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-07-17 15:16:00,448 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local60204158_0005
2015-07-17 15:16:00,448 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:00,452 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:00,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:00,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:00,470 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,470 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-07-17 15:16:00,509 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-07-17 15:16:00,569 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-07-17 15:16:00,583 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:00,584 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:00,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:00,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-07-17 15:16:00,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:00,599 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:00,600 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:00,600 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-07-17 15:16:00,752 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1376342292_0006
2015-07-17 15:16:00,753 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:00,757 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:00,767 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:00,768 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:00,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-07-17 15:16:00,803 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-07-17 15:16:00,868 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-07-17 15:16:00,881 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:00,882 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:00,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-07-17 15:16:00,898 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:00,899 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:00,912 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:00,912 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:00,913 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-07-17 15:16:00,913 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:00,913 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:00,913 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:00,914 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-07-17 15:16:01,037 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1392928273_0007
2015-07-17 15:16:01,038 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:01,041 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:01,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:01,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:01,056 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,057 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-07-17 15:16:01,087 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-07-17 15:16:01,143 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-07-17 15:16:01,158 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:01,159 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:01,175 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:01,175 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,175 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-07-17 15:16:01,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:01,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:01,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:01,176 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-07-17 15:16:01,307 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local524491630_0008
2015-07-17 15:16:01,307 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:01,311 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:01,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:01,321 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:01,326 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,326 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-07-17 15:16:01,366 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-07-17 15:16:01,416 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-07-17 15:16:01,427 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:01,428 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:01,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:01,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-07-17 15:16:01,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:01,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:01,443 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:01,444 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-07-17 15:16:01,555 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local395934512_0009
2015-07-17 15:16:01,556 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:01,560 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:01,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:01,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:01,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-07-17 15:16:01,592 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-07-17 15:16:01,639 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-07-17 15:16:01,651 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:01,652 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:01,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:01,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-07-17 15:16:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:01,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:01,664 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-07-17 15:16:01,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1095137483_0010
2015-07-17 15:16:01,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:01,831 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:01,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:01,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:01,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-07-17 15:16:01,852 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-07-17 15:16:01,853 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-07-17 15:16:01,854 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-07-17 15:16:01,857 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1095137483_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-07-17 15:16:01,863 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1095137483_0010 state at FAILED
2015-07-17 15:16:01,863 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:01,864 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:01,864 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:01,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:01,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-07-17 15:16:01,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:01,866 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-07-17 15:16:01,867 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-07-17 15:16:01,884 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:01,885 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:01,890 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-07-17 15:16:01,904 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:01,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:01,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:01,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:01,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-07-17 15:16:01,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:01,916 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:01,916 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:01,916 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-07-17 15:16:02,034 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local301712688_0011
2015-07-17 15:16:02,034 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:02,038 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:02,047 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:02,047 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:02,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-07-17 15:16:02,052 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-07-17 15:16:02,053 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-07-17 15:16:02,053 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-07-17 15:16:02,055 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local301712688_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-07-17 15:16:02,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local301712688_0011 state at FAILED
2015-07-17 15:16:02,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:02,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:02,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:02,058 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:02,058 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-07-17 15:16:02,059 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:02,059 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-07-17 15:16:02,059 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-07-17 15:16:02,076 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,077 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,087 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:02,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-07-17 15:16:02,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:02,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:02,088 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:02,089 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-07-17 15:16:02,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local576543218_0012
2015-07-17 15:16:02,210 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:02,213 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:02,221 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:02,221 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:02,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,226 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-07-17 15:16:02,226 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-07-17 15:16:02,227 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-07-17 15:16:02,227 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-07-17 15:16:02,229 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local576543218_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-07-17 15:16:02,231 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local576543218_0012 state at FAILED
2015-07-17 15:16:02,231 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:02,232 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:02,232 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:02,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:02,232 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-07-17 15:16:02,233 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:02,233 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-07-17 15:16:02,233 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-07-17 15:16:02,252 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,252 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,255 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-07-17 15:16:02,267 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,268 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,281 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:02,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-07-17 15:16:02,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:02,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:02,282 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:02,283 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-07-17 15:16:02,395 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local638174300_0013
2015-07-17 15:16:02,395 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:02,398 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:02,406 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:02,407 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:02,410 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,411 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-07-17 15:16:02,434 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-07-17 15:16:02,480 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-07-17 15:16:02,493 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,494 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,497 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-07-17 15:16:02,513 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,514 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,527 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:02,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-07-17 15:16:02,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:02,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:02,528 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:02,529 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-07-17 15:16:02,635 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1909566210_0014
2015-07-17 15:16:02,635 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:02,639 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:02,648 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:02,648 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:02,653 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,654 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-07-17 15:16:02,671 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-07-17 15:16:02,729 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-07-17 15:16:02,742 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,743 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:02,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-07-17 15:16:02,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:02,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:02,758 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:02,759 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-07-17 15:16:02,876 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1252546847_0015
2015-07-17 15:16:02,876 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:02,879 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:02,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:02,889 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:02,894 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,894 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-07-17 15:16:02,913 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-07-17 15:16:02,960 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-07-17 15:16:02,971 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:02,971 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:02,981 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-07-17 15:16:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:02,983 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-07-17 15:16:03,089 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1989021269_0016
2015-07-17 15:16:03,089 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:03,094 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:03,107 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:03,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:03,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,113 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-07-17 15:16:03,139 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-07-17 15:16:03,192 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-07-17 15:16:03,203 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:03,203 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-07-17 15:16:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:03,215 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:03,216 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:03,216 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-07-17 15:16:03,322 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1481407691_0017
2015-07-17 15:16:03,322 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:03,325 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:03,333 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:03,333 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:03,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-07-17 15:16:03,361 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-07-17 15:16:03,406 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-07-17 15:16:03,420 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:03,420 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:03,434 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:03,434 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-07-17 15:16:03,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:03,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:03,435 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:03,436 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-07-17 15:16:03,556 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local737334301_0018
2015-07-17 15:16:03,557 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:03,559 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:03,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:03,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:03,572 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,572 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-07-17 15:16:03,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-07-17 15:16:03,640 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-07-17 15:16:03,651 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:03,651 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:03,654 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-07-17 15:16:03,665 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:03,666 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:03,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:03,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-07-17 15:16:03,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:03,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:03,678 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:03,678 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-07-17 15:16:03,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1329340066_0019
2015-07-17 15:16:03,783 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:03,786 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:03,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:03,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:03,799 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,799 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-07-17 15:16:03,822 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-07-17 15:16:03,866 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-07-17 15:16:03,878 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:03,878 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:03,892 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:03,893 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-07-17 15:16:03,996 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1595678330_0020
2015-07-17 15:16:03,996 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:03,999 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,011 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,011 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-07-17 15:16:04,033 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-07-17 15:16:04,081 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-07-17 15:16:04,092 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,092 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:04,100 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:04,101 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-07-17 15:16:04,214 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1000811620_0021
2015-07-17 15:16:04,215 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:04,217 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,229 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,229 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-07-17 15:16:04,230 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-07-17 15:16:04,230 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-07-17 15:16:04,231 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-07-17 15:16:04,233 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1000811620_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-07-17 15:16:04,238 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1000811620_0021 state at FAILED
2015-07-17 15:16:04,239 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:04,239 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:04,239 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:04,239 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:04,239 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-07-17 15:16:04,240 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:04,240 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-07-17 15:16:04,240 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-07-17 15:16:04,255 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,255 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,257 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-07-17 15:16:04,268 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,268 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,275 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:04,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-07-17 15:16:04,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:04,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:04,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:04,277 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-07-17 15:16:04,383 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1115366494_0022
2015-07-17 15:16:04,384 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:04,387 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,395 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,395 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,399 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,400 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-07-17 15:16:04,400 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-07-17 15:16:04,401 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-07-17 15:16:04,401 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-07-17 15:16:04,403 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1115366494_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-07-17 15:16:04,405 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local1115366494_0022 state at FAILED
2015-07-17 15:16:04,406 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:04,406 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:04,406 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:04,406 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:04,406 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-07-17 15:16:04,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:04,407 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-07-17 15:16:04,407 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-07-17 15:16:04,422 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,423 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,431 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:04,431 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,431 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-07-17 15:16:04,432 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:04,432 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:04,432 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:04,433 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-07-17 15:16:04,545 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local954270238_0023
2015-07-17 15:16:04,545 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:04,548 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,560 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,560 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-07-17 15:16:04,561 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-07-17 15:16:04,561 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-07-17 15:16:04,561 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-07-17 15:16:04,563 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local954270238_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-07-17 15:16:04,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] hadoop job job_local954270238_0023 state at FAILED
2015-07-17 15:16:04,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] failure info: NA
2015-07-17 15:16:04,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events identify failed tasks
2015-07-17 15:16:04,566 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [each.each] task completion events count: 0
2015-07-17 15:16:04,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopping all jobs
2015-07-17 15:16:04,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-07-17 15:16:04,567 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] stopped all jobs
2015-07-17 15:16:04,567 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-07-17 15:16:04,567 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-07-17 15:16:04,580 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,580 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:04,594 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,594 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-07-17 15:16:04,594 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:04,594 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:04,594 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:04,595 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-07-17 15:16:04,700 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1384191611_0024
2015-07-17 15:16:04,700 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:04,704 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,715 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,715 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-07-17 15:16:04,736 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-07-17 15:16:04,779 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-07-17 15:16:04,795 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,795 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,798 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-07-17 15:16:04,808 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:04,808 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:04,818 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:04,819 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-07-17 15:16:04,923 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1519452322_0025
2015-07-17 15:16:04,923 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:04,926 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:04,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:04,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:04,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:04,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-07-17 15:16:04,959 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-07-17 15:16:05,004 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-07-17 15:16:05,015 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,015 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,017 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-07-17 15:16:05,027 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,028 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:05,039 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:05,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-07-17 15:16:05,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local725936554_0026
2015-07-17 15:16:05,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:05,149 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:05,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:05,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:05,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-07-17 15:16:05,182 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-07-17 15:16:05,228 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-07-17 15:16:05,242 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,242 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:05,252 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:05,253 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-07-17 15:16:05,359 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1490237243_0027
2015-07-17 15:16:05,360 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:05,362 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:05,370 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:05,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:05,374 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,374 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-07-17 15:16:05,396 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-07-17 15:16:05,439 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-07-17 15:16:05,451 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,452 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,463 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:05,463 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,464 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-07-17 15:16:05,464 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:05,464 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:05,464 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:05,465 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-07-17 15:16:05,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local108690852_0028
2015-07-17 15:16:05,568 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:05,570 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:05,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:05,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:05,582 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,582 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-07-17 15:16:05,604 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-07-17 15:16:05,650 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-07-17 15:16:05,661 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,662 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:05,672 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-07-17 15:16:05,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:05,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:05,673 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:05,673 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-07-17 15:16:05,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1676829290_0029
2015-07-17 15:16:05,779 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:05,781 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:05,790 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:05,790 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:05,794 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,794 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-07-17 15:16:05,815 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-07-17 15:16:05,858 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-07-17 15:16:05,868 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:05,869 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:05,877 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:05,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:05,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-07-17 15:16:05,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:05,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:05,878 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:05,878 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-07-17 15:16:05,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local864083651_0030
2015-07-17 15:16:05,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:05,988 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:05,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:05,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:06,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:06,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-07-17 15:16:06,022 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-07-17 15:16:06,065 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-07-17 15:16:06,076 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:06,076 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:06,086 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each] starting
2015-07-17 15:16:06,086 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:06,086 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-07-17 15:16:06,087 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  parallel execution is enabled: false
2015-07-17 15:16:06,087 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  starting jobs: 1
2015-07-17 15:16:06,087 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [each.each]  allocating threads: 1
2015-07-17 15:16:06,087 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-07-17 15:16:06,190 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] submitted hadoop job: job_local1030792952_0031
2015-07-17 15:16:06,190 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [each.each] tracking url: http://localhost:8080/
2015-07-17 15:16:06,193 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt
2015-07-17 15:16:06,202 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:16:06,202 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:16:06,205 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 15:16:06,205 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-07-17 15:16:06,229 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-07-17 15:16:06,275 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-07-17 15:16:06,286 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:16:06,286 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:16:06,289 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]