Class cascading.detail.EachEachPipeAssemblyPlatformTest

40

tests

0

failures

1m19.02s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 3.163s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 3.183s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 3.912s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 3.140s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 3.138s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.010s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.021s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 3.096s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 3.114s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 3.117s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 3.098s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 3.118s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.010s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.070s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.065s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.067s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 3.080s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 3.085s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 3.080s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 3.098s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.008s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 3.086s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.009s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 3.083s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.008s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 3.079s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 3.084s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 3.085s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.019s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.068s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.075s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.073s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 3.079s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 3.082s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 3.192s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 3.085s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 3.105s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.007s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 3.111s passed

Standard output

2013-10-31 20:02:51,853 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-31 20:02:51,872 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-31 20:02:51,872 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EachEachPipeAssemblyPlatformTest
2013-10-31 20:02:51,897 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,907 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,914 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,920 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,925 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,929 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,934 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,934 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,938 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,942 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,945 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,945 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,945 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,947 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,947 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,947 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,951 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,951 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,954 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,959 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,964 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,969 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,972 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,973 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,975 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,978 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,978 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,979 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,979 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,979 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,982 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,982 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,984 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,985 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,987 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,990 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,992 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,994 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,997 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:51,999 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-31 20:02:52,104 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-31 20:02:52,440 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:02:52,441 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:02:52,450 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: C73804FFDB8A4050A06C16F036FDDF8B
2013-10-31 20:02:52,595 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-31 20:02:52,597 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:02:52,597 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:52,598 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-31 20:02:52,598 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:02:52,598 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:02:52,598 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:02:52,599 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2013-10-31 20:02:52,624 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-31 20:02:52,628 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:02:52,629 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:02:52,653 INFO  security.ShellBasedUnixGroupsMapping (ShellBasedUnixGroupsMapping.java:getUnixGroups(89)) - add hadoop to shell userGroupsCache
2013-10-31 20:02:52,659 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:02:52,682 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-10-31 20:02:52,686 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:52,904 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0001
2013-10-31 20:02:52,934 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:02:52,941 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-10-31 20:02:52,944 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@27fac6e2
2013-10-31 20:02:52,949 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:02:52,954 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:02:52,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:02:52,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:02:53,012 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:53,012 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-31 20:02:53,022 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:02:53,025 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:02:53,025 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-10-31 20:02:53,028 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-31 20:02:55,936 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:02:55,937 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-31 20:02:55,959 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2013-10-31 20:02:55,997 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:56,013 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:56,014 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-31 20:02:56,029 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:02:56,029 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:02:56,046 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:02:56,047 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:56,047 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-31 20:02:56,048 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:02:56,048 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:02:56,048 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:02:56,049 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2013-10-31 20:02:56,054 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:02:56,054 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:02:56,074 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:02:56,077 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:56,134 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0002
2013-10-31 20:02:56,137 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:02:56,139 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@57d21cd6
2013-10-31 20:02:56,142 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:02:56,144 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:02:56,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:02:56,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:02:56,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:56,163 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-31 20:02:56,165 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:02:56,165 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:02:56,166 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-10-31 20:02:56,168 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-31 20:02:59,139 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:02:59,141 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-31 20:02:59,152 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2013-10-31 20:02:59,181 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:59,197 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:59,198 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-31 20:02:59,211 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:02:59,211 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:02:59,227 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:02:59,227 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:59,228 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-31 20:02:59,228 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:02:59,228 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:02:59,228 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:02:59,229 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2013-10-31 20:02:59,231 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:02:59,231 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:02:59,239 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:02:59,241 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:02:59,289 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0003
2013-10-31 20:02:59,307 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:02:59,309 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@49f2bca4
2013-10-31 20:02:59,310 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:02:59,311 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:02:59,317 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:02:59,317 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:02:59,331 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:02:59,332 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-31 20:02:59,333 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:02:59,334 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:02:59,335 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2013-10-31 20:02:59,337 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-31 20:03:02,309 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:02,311 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-31 20:03:02,323 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2013-10-31 20:03:02,345 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:02,360 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:02,361 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-31 20:03:02,369 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:02,369 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:02,383 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:02,384 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:02,384 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-31 20:03:02,385 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:02,385 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:02,386 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:02,387 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2013-10-31 20:03:02,392 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:02,392 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:02,412 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:02,416 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:02,442 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0004
2013-10-31 20:03:02,446 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:02,448 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4ae6120d
2013-10-31 20:03:02,450 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:02,452 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:02,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:02,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:02,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:02,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-31 20:03:02,477 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:02,478 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:02,478 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-10-31 20:03:02,480 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-31 20:03:05,448 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:05,449 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0004_m_000000_0' done.
2013-10-31 20:03:05,460 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2013-10-31 20:03:05,481 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:05,498 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:05,499 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-31 20:03:05,507 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:05,507 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:05,520 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:05,521 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:05,521 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-31 20:03:05,522 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:05,522 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:05,522 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:05,523 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2013-10-31 20:03:05,529 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:05,529 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:05,549 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:05,553 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:05,581 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0005
2013-10-31 20:03:05,583 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:05,584 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@18bfd73e
2013-10-31 20:03:05,585 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:05,586 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:05,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:05,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:05,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:05,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-31 20:03:05,597 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:05,598 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:05,598 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-10-31 20:03:05,601 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-31 20:03:08,585 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:08,586 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0005_m_000000_0' done.
2013-10-31 20:03:08,600 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2013-10-31 20:03:08,622 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:08,639 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:08,640 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-31 20:03:08,647 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:08,648 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:08,660 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:08,661 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:08,661 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-31 20:03:08,662 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:08,662 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:08,662 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:08,663 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2013-10-31 20:03:08,666 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:08,666 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:08,676 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:08,678 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:08,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0006
2013-10-31 20:03:08,704 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:08,705 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@96a688a
2013-10-31 20:03:08,705 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:08,706 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:08,708 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:08,709 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:08,715 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:08,716 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-31 20:03:08,718 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:08,718 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:08,719 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2013-10-31 20:03:08,721 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-31 20:03:11,705 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:11,707 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0006_m_000000_0' done.
2013-10-31 20:03:11,719 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2013-10-31 20:03:11,738 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:11,756 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:11,757 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-31 20:03:11,764 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:11,764 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:11,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2013-10-31 20:03:11,775 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:11,776 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:11,787 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:11,788 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:11,788 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-31 20:03:11,789 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:11,789 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:11,789 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:11,790 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2013-10-31 20:03:11,794 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:11,795 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:11,813 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:11,816 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:11,837 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0007
2013-10-31 20:03:11,839 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:11,840 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3fe9967b
2013-10-31 20:03:11,841 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:11,841 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:11,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:11,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:11,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:11,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-31 20:03:11,852 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:11,852 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:11,853 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2013-10-31 20:03:11,855 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-31 20:03:14,841 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:14,842 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0007_m_000000_0' done.
2013-10-31 20:03:14,855 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2013-10-31 20:03:14,873 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:14,882 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:14,883 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-31 20:03:14,889 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:14,889 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:14,901 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:14,902 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:14,902 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-31 20:03:14,903 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:14,903 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:14,903 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:14,904 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2013-10-31 20:03:14,908 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:14,908 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:14,922 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:14,926 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:14,951 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0008
2013-10-31 20:03:14,955 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:14,956 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7fdcc07b
2013-10-31 20:03:14,958 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:14,960 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:14,965 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:14,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:14,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:14,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-31 20:03:14,979 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:14,979 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:14,980 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-10-31 20:03:14,981 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-31 20:03:17,957 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:17,958 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0008_m_000000_0' done.
2013-10-31 20:03:17,969 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2013-10-31 20:03:17,987 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:18,000 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:18,000 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-31 20:03:18,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:18,008 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:18,019 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-31 20:03:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:18,020 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:18,021 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2013-10-31 20:03:18,023 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:18,023 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:18,028 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:18,030 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:18,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0009
2013-10-31 20:03:18,053 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:18,054 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3f0c0cb9
2013-10-31 20:03:18,056 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:18,056 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:18,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:18,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:18,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:18,064 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-31 20:03:18,066 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:18,067 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:18,067 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0009_m_000000_0 is allowed to commit now
2013-10-31 20:03:18,069 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-31 20:03:21,054 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:21,056 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0009_m_000000_0' done.
2013-10-31 20:03:21,065 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2013-10-31 20:03:21,083 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,098 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,099 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-31 20:03:21,105 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,105 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,117 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:21,117 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,118 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-31 20:03:21,119 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:21,119 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:21,119 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:21,120 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-31 20:03:21,122 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:21,122 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:21,128 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:21,129 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,145 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0010
2013-10-31 20:03:21,147 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:21,148 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@9437a04
2013-10-31 20:03:21,149 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:21,149 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:21,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:21,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:21,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,157 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-31 20:03:21,158 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,160 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,160 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,161 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,166 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:21,166 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:21,166 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:21,167 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-31 20:03:21,168 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:21,168 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2013-10-31 20:03:21,168 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2013-10-31 20:03:21,175 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,175 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,179 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2013-10-31 20:03:21,185 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,185 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,196 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:21,196 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,196 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-31 20:03:21,197 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:21,197 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:21,197 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:21,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-31 20:03:21,200 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:21,200 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:21,205 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:21,207 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,223 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0011
2013-10-31 20:03:21,225 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:21,226 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1b0efc5e
2013-10-31 20:03:21,227 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:21,228 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:21,230 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:21,230 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:21,235 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-31 20:03:21,236 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,237 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,237 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,238 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0011
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,244 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:21,244 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:21,244 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:21,245 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-31 20:03:21,245 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:21,245 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2013-10-31 20:03:21,245 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2013-10-31 20:03:21,253 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,253 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,263 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:21,263 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,264 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-31 20:03:21,264 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:21,264 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:21,264 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:21,265 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-31 20:03:21,266 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:21,266 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:21,271 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:21,273 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,288 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0012
2013-10-31 20:03:21,291 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:21,291 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@22d0280b
2013-10-31 20:03:21,292 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:21,293 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:21,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:21,295 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:21,300 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,300 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-31 20:03:21,301 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,301 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,302 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,303 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0012
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:21,309 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:21,309 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:21,309 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:21,310 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-31 20:03:21,310 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:21,310 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2013-10-31 20:03:21,310 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2013-10-31 20:03:21,317 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,317 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,320 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2013-10-31 20:03:21,327 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:21,327 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:21,337 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-31 20:03:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:21,338 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:21,339 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2013-10-31 20:03:21,341 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:21,341 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:21,346 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:21,347 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:21,363 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0013
2013-10-31 20:03:21,365 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:21,366 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5d80b129
2013-10-31 20:03:21,367 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:21,367 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:21,369 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:21,369 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:21,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:21,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-31 20:03:21,377 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:21,377 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:21,377 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0013_m_000000_0 is allowed to commit now
2013-10-31 20:03:21,379 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-31 20:03:24,367 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:24,368 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0013_m_000000_0' done.
2013-10-31 20:03:24,381 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2013-10-31 20:03:24,399 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:24,416 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:24,417 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-31 20:03:24,432 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:24,433 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:24,437 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2013-10-31 20:03:24,443 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:24,444 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:24,452 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:24,452 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-31 20:03:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:24,453 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:24,453 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2013-10-31 20:03:24,455 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:24,455 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:24,460 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:24,462 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:24,478 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0014
2013-10-31 20:03:24,479 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:24,480 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23d63a83
2013-10-31 20:03:24,481 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:24,481 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:24,483 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:24,483 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:24,488 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:24,488 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-31 20:03:24,490 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:24,491 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:24,491 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2013-10-31 20:03:24,492 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-31 20:03:27,150 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:27,228 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:27,293 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:27,480 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:27,481 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0014_m_000000_0' done.
2013-10-31 20:03:27,496 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2013-10-31 20:03:27,513 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:27,522 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:27,523 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-31 20:03:27,529 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:27,529 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:27,539 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:27,539 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:27,539 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-31 20:03:27,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:27,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:27,540 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:27,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2013-10-31 20:03:27,542 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:27,542 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:27,548 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:27,549 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:27,564 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0015
2013-10-31 20:03:27,566 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:27,567 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@13cb35da
2013-10-31 20:03:27,568 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:27,568 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:27,570 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:27,570 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:27,576 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:27,576 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-31 20:03:27,577 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:27,578 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:27,578 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0015_m_000000_0 is allowed to commit now
2013-10-31 20:03:27,580 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-31 20:03:30,567 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:30,569 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0015_m_000000_0' done.
2013-10-31 20:03:30,574 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2013-10-31 20:03:30,592 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:30,602 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:30,603 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-31 20:03:30,609 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:30,609 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:30,618 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:30,618 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:30,619 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-31 20:03:30,619 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:30,619 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:30,619 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:30,620 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2013-10-31 20:03:30,621 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:30,622 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:30,627 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:30,628 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:30,644 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0016
2013-10-31 20:03:30,665 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:30,666 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@64dd4991
2013-10-31 20:03:30,668 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:30,668 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:30,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:30,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:30,675 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:30,675 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-31 20:03:30,677 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0016_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:30,677 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:30,678 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0016_m_000000_0 is allowed to commit now
2013-10-31 20:03:30,679 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-31 20:03:33,666 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:33,668 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0016_m_000000_0' done.
2013-10-31 20:03:33,675 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2013-10-31 20:03:33,691 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:33,700 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:33,701 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-31 20:03:33,707 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:33,707 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:33,715 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:33,716 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:33,716 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-31 20:03:33,716 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:33,716 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:33,717 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:33,717 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2013-10-31 20:03:33,719 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:33,719 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:33,724 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:33,725 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:33,739 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0017
2013-10-31 20:03:33,741 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:33,742 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2c186288
2013-10-31 20:03:33,742 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:33,743 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:33,745 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:33,745 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:33,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:33,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-31 20:03:33,751 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0017_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:33,751 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:33,752 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0017_m_000000_0 is allowed to commit now
2013-10-31 20:03:33,753 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-31 20:03:36,742 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:36,743 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0017_m_000000_0' done.
2013-10-31 20:03:36,757 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2013-10-31 20:03:36,772 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:36,781 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:36,781 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-31 20:03:36,787 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:36,787 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:36,795 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:36,796 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:36,796 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-31 20:03:36,796 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:36,797 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:36,797 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:36,797 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2013-10-31 20:03:36,799 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:36,799 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:36,803 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:36,804 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:36,817 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0018
2013-10-31 20:03:36,821 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:36,822 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@228bf650
2013-10-31 20:03:36,824 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:36,825 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:36,829 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:36,829 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:36,838 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:36,838 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-31 20:03:36,840 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0018_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:36,840 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:36,840 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0018_m_000000_0 is allowed to commit now
2013-10-31 20:03:36,842 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-31 20:03:39,822 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:39,823 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0018_m_000000_0' done.
2013-10-31 20:03:39,835 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2013-10-31 20:03:39,850 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:39,860 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:39,860 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-31 20:03:39,866 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:39,866 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:39,869 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2013-10-31 20:03:39,874 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:39,875 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:39,882 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:39,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:39,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-31 20:03:39,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:39,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:39,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:39,884 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2013-10-31 20:03:39,885 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:39,885 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:39,889 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:39,890 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:39,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0019
2013-10-31 20:03:39,905 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:39,905 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5c0b4e04
2013-10-31 20:03:39,906 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:39,907 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:39,908 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:39,908 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:39,912 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:39,913 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-31 20:03:39,914 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0019_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:39,915 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:39,915 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0019_m_000000_0 is allowed to commit now
2013-10-31 20:03:39,916 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0019_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-31 20:03:42,906 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:42,907 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0019_m_000000_0' done.
2013-10-31 20:03:42,921 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2013-10-31 20:03:42,936 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:42,952 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:42,953 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-31 20:03:42,960 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:42,961 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:42,969 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:42,969 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:42,969 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-31 20:03:42,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:42,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:42,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:42,971 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2013-10-31 20:03:42,972 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:42,972 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:42,976 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:42,977 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:42,991 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0020
2013-10-31 20:03:42,993 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:42,993 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6c82c0b7
2013-10-31 20:03:42,994 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:42,995 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:42,996 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:42,996 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:43,000 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:43,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-31 20:03:43,002 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0020_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:43,003 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:43,003 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0020_m_000000_0 is allowed to commit now
2013-10-31 20:03:43,004 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0020_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-31 20:03:45,993 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:45,995 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0020_m_000000_0' done.
2013-10-31 20:03:46,008 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2013-10-31 20:03:46,024 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,037 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,038 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-31 20:03:46,043 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:46,044 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:46,051 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:46,051 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,052 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-31 20:03:46,052 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:46,052 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:46,053 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:46,053 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-31 20:03:46,055 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:46,055 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:46,059 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:46,060 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,073 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0021
2013-10-31 20:03:46,076 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:46,078 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@501b7924
2013-10-31 20:03:46,079 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:46,081 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:46,085 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:46,085 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:46,096 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,096 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-31 20:03:46,097 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,097 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,098 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,099 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0021
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,104 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:46,104 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:46,104 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:46,104 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-31 20:03:46,105 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:46,105 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2013-10-31 20:03:46,106 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2013-10-31 20:03:46,119 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:46,120 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:46,126 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2013-10-31 20:03:46,137 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:46,138 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:46,145 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:46,145 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-31 20:03:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:46,147 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-31 20:03:46,149 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:46,149 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:46,153 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:46,154 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0022
2013-10-31 20:03:46,169 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:46,171 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5f18d1f9
2013-10-31 20:03:46,172 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:46,174 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:46,177 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:46,178 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:46,188 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,189 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-31 20:03:46,190 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,191 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,193 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,196 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0022
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,197 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:46,197 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:46,197 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:46,198 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-31 20:03:46,199 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:46,199 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2013-10-31 20:03:46,199 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2013-10-31 20:03:46,212 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:46,213 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:46,221 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:46,222 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-31 20:03:46,223 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:46,223 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:46,227 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:46,228 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,240 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0023
2013-10-31 20:03:46,243 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:46,245 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1d75ccb0
2013-10-31 20:03:46,247 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:46,248 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:46,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:46,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:46,262 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,262 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-31 20:03:46,264 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,265 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,267 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:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,270 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0023
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:99)
	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:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	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:127)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-31 20:03:46,271 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events identify failed tasks
2013-10-31 20:03:46,272 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [each.each] task completion events count: 0
2013-10-31 20:03:46,272 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopping all jobs
2013-10-31 20:03:46,272 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-31 20:03:46,273 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] stopped all jobs
2013-10-31 20:03:46,274 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2013-10-31 20:03:46,274 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2013-10-31 20:03:46,288 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:46,288 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:46,299 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:46,299 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,299 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-31 20:03:46,299 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:46,300 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:46,300 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:46,300 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2013-10-31 20:03:46,301 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:46,301 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:46,305 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:46,306 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:46,319 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0024
2013-10-31 20:03:46,322 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:46,323 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1ef10853
2013-10-31 20:03:46,325 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:46,327 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:46,330 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:46,330 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:46,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:46,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-31 20:03:46,340 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0024_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:46,340 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:46,341 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0024_m_000000_0 is allowed to commit now
2013-10-31 20:03:46,342 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0024_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-31 20:03:49,323 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:49,324 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0024_m_000000_0' done.
2013-10-31 20:03:49,336 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2013-10-31 20:03:49,350 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:49,360 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:49,360 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-31 20:03:49,366 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:49,366 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:49,369 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2013-10-31 20:03:49,374 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:49,374 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:49,381 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:49,381 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:49,382 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-31 20:03:49,382 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:49,382 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:49,382 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:49,383 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2013-10-31 20:03:49,385 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:49,385 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:49,389 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:49,390 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:49,403 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0025
2013-10-31 20:03:49,405 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:49,405 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2a72f1ca
2013-10-31 20:03:49,406 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:49,407 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:49,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:49,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:49,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:49,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-31 20:03:49,414 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0025_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:49,415 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:49,415 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0025_m_000000_0 is allowed to commit now
2013-10-31 20:03:49,416 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0025_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-31 20:03:52,079 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:52,171 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:52,246 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:52,406 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:52,407 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0025_m_000000_0' done.
2013-10-31 20:03:52,420 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2013-10-31 20:03:52,435 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:52,450 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:52,452 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-31 20:03:52,460 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:52,460 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:52,462 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2013-10-31 20:03:52,467 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:52,468 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:52,474 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:52,475 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:52,475 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-31 20:03:52,476 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:52,476 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:52,476 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:52,477 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2013-10-31 20:03:52,575 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:52,575 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:52,585 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:52,588 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:52,606 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0026
2013-10-31 20:03:52,609 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:52,610 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7d0e06bf
2013-10-31 20:03:52,612 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:52,613 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:52,616 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:52,617 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:52,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:52,627 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-31 20:03:52,632 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0026_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:52,633 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:52,634 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0026_m_000000_0 is allowed to commit now
2013-10-31 20:03:52,636 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0026_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-31 20:03:55,610 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:55,611 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0026_m_000000_0' done.
2013-10-31 20:03:55,624 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2013-10-31 20:03:55,638 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:55,653 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:55,654 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-31 20:03:55,661 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:55,661 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:55,667 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:55,668 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:55,668 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-31 20:03:55,668 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:55,669 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:55,669 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:55,670 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2013-10-31 20:03:55,671 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:55,671 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:55,675 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:55,677 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:55,689 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0027
2013-10-31 20:03:55,693 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:55,694 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2cc78bb5
2013-10-31 20:03:55,696 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:55,697 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:55,701 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:55,701 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:55,711 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:55,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-31 20:03:55,716 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0027_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:55,717 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:55,717 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0027_m_000000_0 is allowed to commit now
2013-10-31 20:03:55,718 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0027_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-31 20:03:58,694 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:03:58,695 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0027_m_000000_0' done.
2013-10-31 20:03:58,706 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2013-10-31 20:03:58,720 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:58,735 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:58,736 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-31 20:03:58,742 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:03:58,743 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:03:58,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:03:58,750 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2013-10-31 20:03:58,751 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:03:58,751 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:03:58,755 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:03:58,756 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:03:58,768 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0028
2013-10-31 20:03:58,771 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:03:58,772 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@165436d0
2013-10-31 20:03:58,774 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:03:58,776 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:03:58,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:03:58,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:03:58,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:03:58,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-31 20:03:58,794 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0028_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:03:58,795 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:03:58,796 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0028_m_000000_0 is allowed to commit now
2013-10-31 20:03:58,797 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0028_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-31 20:04:01,772 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:04:01,774 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0028_m_000000_0' done.
2013-10-31 20:04:01,785 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2013-10-31 20:04:01,799 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:01,814 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:01,816 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-31 20:04:01,821 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:04:01,822 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:04:01,828 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:04:01,829 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:01,829 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-31 20:04:01,829 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:04:01,830 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:04:01,830 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:04:01,831 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2013-10-31 20:04:01,832 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:04:01,832 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:04:01,836 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:04:01,837 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:01,879 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0029
2013-10-31 20:04:01,881 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:04:01,881 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@75e04c59
2013-10-31 20:04:01,882 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:04:01,883 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:04:01,884 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:04:01,884 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:04:01,888 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:01,888 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-31 20:04:01,890 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0029_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:04:01,891 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:04:01,891 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0029_m_000000_0 is allowed to commit now
2013-10-31 20:04:01,892 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0029_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-31 20:04:04,882 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:04:04,883 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0029_m_000000_0' done.
2013-10-31 20:04:04,896 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2013-10-31 20:04:04,912 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:04,921 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:04,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-31 20:04:04,926 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:04:04,927 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:04:04,933 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:04:04,933 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:04,934 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-31 20:04:04,934 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:04:04,934 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:04:04,935 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:04:04,936 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2013-10-31 20:04:04,937 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:04:04,937 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:04:04,941 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:04:04,942 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:04,954 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0030
2013-10-31 20:04:04,957 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:04:04,958 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23b1293f
2013-10-31 20:04:04,960 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:04:04,961 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:04:04,965 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:04:04,965 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:04:04,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:04,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-31 20:04:04,978 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0030_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:04:04,978 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:04:04,979 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0030_m_000000_0 is allowed to commit now
2013-10-31 20:04:04,980 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0030_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-31 20:04:07,958 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:04:07,959 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0030_m_000000_0' done.
2013-10-31 20:04:07,990 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2013-10-31 20:04:08,000 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:08,006 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:08,007 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-31 20:04:08,012 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:04:08,013 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:04:08,034 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each] starting
2013-10-31 20:04:08,037 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:08,037 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-31 20:04:08,038 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  parallel execution is enabled: false
2013-10-31 20:04:08,039 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  starting jobs: 1
2013-10-31 20:04:08,040 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [each.each]  allocating threads: 1
2013-10-31 20:04:08,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2013-10-31 20:04:08,052 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(825)) - Default number of map tasks: 1
2013-10-31 20:04:08,053 INFO  mapred.JobClient (JobClient.java:setNumTasksBasedOnClusterCapacity(832)) - Default number of reduce tasks: 0
2013-10-31 20:04:08,056 INFO  mapred.JobClient (JobClient.java:copyAndConfigureFiles(794)) - Setting group to hadoop
2013-10-31 20:04:08,058 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:08,072 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [each.each] submitted hadoop job: job_local_0031
2013-10-31 20:04:08,076 INFO  mapred.MapTask (MapTask.java:run(352)) - Host name: ip-10-5-128-102.ec2.internal
2013-10-31 20:04:08,077 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4e5bf0a9
2013-10-31 20:04:08,079 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt
2013-10-31 20:04:08,080 INFO  mapred.MapTask (MapTask.java:runOldMapper(430)) - numReduceTasks: 0
2013-10-31 20:04:08,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-31 20:04:08,084 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: 
2013-10-31 20:04:08,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt"]
2013-10-31 20:04:08,094 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-31 20:04:08,097 INFO  mapred.Task (Task.java:done(852)) - Task:attempt_local_0031_m_000000_0 is done. And is in the process of commiting
2013-10-31 20:04:08,098 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-31 20:04:08,098 INFO  mapred.Task (Task.java:commit(1005)) - Task attempt_local_0031_m_000000_0 is allowed to commit now
2013-10-31 20:04:08,099 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0031_m_000000_0' to file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-31 20:04:11,077 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/classes/test/data/nums.20.txt:0+51
2013-10-31 20:04:11,078 INFO  mapred.Task (Task.java:sendDone(964)) - Task 'attempt_local_0031_m_000000_0' done.
2013-10-31 20:04:11,090 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output/hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2013-10-31 20:04:11,104 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:11,118 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-31 20:04:11,118 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-31 20:04:11,123 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-31 20:04:11,124 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /home/hadoop/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-31 20:04:11,126 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/hadoop/cascading.compatibility/amazon-emr-2.4.2/build/test/output//hadoop/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'