Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

6.771s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 0.384s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 0.292s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 1.290s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 0.364s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 0.280s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.029s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.010s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 0.167s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 0.186s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.026s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 0.262s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 0.194s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 0.138s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.030s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.204s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.190s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.173s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 0.189s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 0.118s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 0.106s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 0.115s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 0.107s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.011s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 0.110s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.013s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 0.131s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 0.268s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 0.171s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.030s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.149s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.127s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.140s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 0.094s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 0.127s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 0.213s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 0.103s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 0.112s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 0.094s passed

Standard output

2013-10-28 18:15:07,650 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-28 18:15:07,675 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-28 18:15:07,676 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2013-10-28 18:15:07,726 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,741 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,749 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,759 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,772 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,785 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,790 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,792 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,797 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,803 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,813 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,814 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,816 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,817 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,819 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,825 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,835 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,836 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,845 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,857 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,861 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,866 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,871 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,872 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,876 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,880 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,881 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,882 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,883 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,884 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,888 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,889 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,893 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,895 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,899 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,903 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,912 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,918 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,922 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:07,926 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2013-10-28 18:15:08,091 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-28 18:15:08,558 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:08,561 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:08,573 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: E7EC478840B04069894138E33C62DCF8
2013-10-28 18:15:08,798 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-28 18:15:08,801 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:08,803 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:08,803 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-28 18:15:08,804 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:08,805 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:08,806 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:08,807 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2013-10-28 18:15:08,843 INFO  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(40)) - Trying to load the custom-built native-hadoop library...
2013-10-28 18:15:08,847 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(47)) - Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path
2013-10-28 18:15:08,847 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(48)) - java.library.path=/usr/java/jdk1.6.0_31/jre/lib/amd64/server:/usr/java/jdk1.6.0_31/jre/lib/amd64:/usr/java/jdk1.6.0_31/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2013-10-28 18:15:08,848 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-28 18:15:08,910 ERROR snappy.LoadSnappy (LoadSnappy.java:<clinit>(51)) - Failed to load snappy with error: java.lang.UnsatisfiedLinkError: no snappy in java.library.path
2013-10-28 18:15:08,911 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(63)) - Snappy native library not loaded
2013-10-28 18:15:08,917 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,118 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0001
2013-10-28 18:15:09,193 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:09,194 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:09,201 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:09,207 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:09,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:09,217 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:09,268 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:09,269 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2013-10-28 18:15:09,280 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:09,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:09,284 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-10-28 18:15:09,287 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-28 18:15:09,288 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:09,289 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-28 18:15:09,300 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2013-10-28 18:15:09,337 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,370 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,376 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2013-10-28 18:15:09,404 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:09,407 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:09,434 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:09,434 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:09,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-28 18:15:09,435 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:09,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:09,436 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:09,437 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2013-10-28 18:15:09,449 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,545 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0002
2013-10-28 18:15:09,549 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:09,549 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:09,551 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:09,554 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:09,559 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:09,559 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:09,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:09,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2013-10-28 18:15:09,574 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:09,575 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:09,576 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-10-28 18:15:09,580 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-28 18:15:09,580 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:09,581 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-28 18:15:09,587 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2013-10-28 18:15:09,623 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,669 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,671 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2013-10-28 18:15:09,703 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:09,704 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:09,753 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:09,753 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:09,754 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-28 18:15:09,754 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:09,754 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:09,754 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:09,761 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2013-10-28 18:15:09,781 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:09,921 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0003
2013-10-28 18:15:09,933 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:09,934 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:09,935 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:09,937 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:09,945 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:09,945 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:09,967 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:09,967 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2013-10-28 18:15:09,970 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:09,971 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:09,983 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2013-10-28 18:15:09,986 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-28 18:15:09,987 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:09,988 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-28 18:15:09,993 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2013-10-28 18:15:10,025 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,053 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,055 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2013-10-28 18:15:10,067 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:10,068 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:10,094 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:10,098 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,101 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-28 18:15:10,102 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:10,103 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:10,104 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:10,109 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2013-10-28 18:15:10,143 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,216 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0004
2013-10-28 18:15:10,221 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:10,222 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:10,223 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:10,226 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:10,234 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:10,236 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:10,251 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2013-10-28 18:15:10,256 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:10,257 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:10,259 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-10-28 18:15:10,263 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-28 18:15:10,264 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:10,265 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0004_m_000000_0' done.
2013-10-28 18:15:10,281 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2013-10-28 18:15:10,299 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,330 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,334 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2013-10-28 18:15:10,367 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:10,369 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:10,402 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:10,404 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,405 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-28 18:15:10,406 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:10,406 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:10,407 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:10,415 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2013-10-28 18:15:10,445 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,551 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0005
2013-10-28 18:15:10,565 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:10,566 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:10,567 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:10,571 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:10,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:10,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:10,614 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,615 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2013-10-28 18:15:10,618 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:10,633 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:10,634 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-10-28 18:15:10,647 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-28 18:15:10,649 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:10,650 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0005_m_000000_0' done.
2013-10-28 18:15:10,663 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2013-10-28 18:15:10,681 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,703 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,708 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2013-10-28 18:15:10,727 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:10,727 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:10,747 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:10,747 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,747 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-28 18:15:10,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:10,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:10,749 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:10,749 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2013-10-28 18:15:10,789 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,862 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0006
2013-10-28 18:15:10,871 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:10,871 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:10,874 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:10,876 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:10,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:10,882 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:10,893 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:10,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2013-10-28 18:15:10,899 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:10,901 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:10,902 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2013-10-28 18:15:10,915 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-28 18:15:10,919 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:10,920 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0006_m_000000_0' done.
2013-10-28 18:15:10,935 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2013-10-28 18:15:10,947 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,966 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:10,970 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2013-10-28 18:15:10,984 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:10,986 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:10,997 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2013-10-28 18:15:11,007 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,009 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,025 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,027 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-28 18:15:11,029 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,030 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,030 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2013-10-28 18:15:11,048 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,111 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0007
2013-10-28 18:15:11,116 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:11,116 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:11,117 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:11,118 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:11,125 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:11,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:11,134 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,135 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2013-10-28 18:15:11,138 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:11,139 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:11,140 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2013-10-28 18:15:11,144 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-28 18:15:11,146 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:11,148 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0007_m_000000_0' done.
2013-10-28 18:15:11,155 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2013-10-28 18:15:11,172 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,184 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,185 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2013-10-28 18:15:11,192 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,193 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,206 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,206 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,206 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-28 18:15:11,207 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,207 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,207 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2013-10-28 18:15:11,220 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,250 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0008
2013-10-28 18:15:11,256 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:11,256 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:11,257 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:11,260 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:11,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:11,263 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:11,285 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2013-10-28 18:15:11,289 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:11,290 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:11,291 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-10-28 18:15:11,294 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-28 18:15:11,295 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:11,297 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0008_m_000000_0' done.
2013-10-28 18:15:11,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2013-10-28 18:15:11,310 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,322 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,324 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2013-10-28 18:15:11,331 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,332 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,350 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,350 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,351 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-28 18:15:11,351 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,352 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,352 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,353 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2013-10-28 18:15:11,365 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,413 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0009
2013-10-28 18:15:11,433 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:11,433 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:11,434 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:11,436 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:11,439 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:11,445 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:11,452 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,452 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2013-10-28 18:15:11,464 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:11,465 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:11,466 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0009_m_000000_0 is allowed to commit now
2013-10-28 18:15:11,474 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0009_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-28 18:15:11,482 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:11,482 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0009_m_000000_0' done.
2013-10-28 18:15:11,488 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2013-10-28 18:15:11,501 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,517 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,518 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2013-10-28 18:15:11,530 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,531 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,565 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,566 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,567 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-28 18:15:11,567 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,568 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,568 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,575 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-28 18:15:11,594 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,657 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0010
2013-10-28 18:15:11,665 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:11,666 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:11,667 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:11,668 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:11,671 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:11,672 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:11,685 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,685 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2013-10-28 18:15:11,690 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,696 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,702 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,709 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,720 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:11,720 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:11,721 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:11,721 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2013-10-28 18:15:11,722 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:11,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2013-10-28 18:15:11,723 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2013-10-28 18:15:11,736 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,746 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,754 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2013-10-28 18:15:11,768 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,774 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,800 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,800 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,801 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-28 18:15:11,801 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,802 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,802 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,808 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-28 18:15:11,823 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:11,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0011
2013-10-28 18:15:11,884 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:11,884 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:11,886 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:11,887 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:11,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:11,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:11,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2013-10-28 18:15:11,907 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,915 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,915 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,917 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:11,924 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:11,924 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:11,925 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:11,925 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2013-10-28 18:15:11,925 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:11,925 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutting down job executor
2013-10-28 18:15:11,926 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutdown complete
2013-10-28 18:15:11,926 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2013-10-28 18:15:11,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2013-10-28 18:15:11,942 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:11,943 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:11,967 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:11,968 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:11,969 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-28 18:15:11,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:11,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:11,970 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:11,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-28 18:15:11,996 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,041 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0012
2013-10-28 18:15:12,051 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,051 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,052 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,056 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,060 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,066 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2013-10-28 18:15:12,083 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:12,088 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:12,088 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:12,090 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:12,092 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:12,110 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:12,110 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:12,110 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2013-10-28 18:15:12,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:12,112 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutting down job executor
2013-10-28 18:15:12,116 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutdown complete
2013-10-28 18:15:12,116 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2013-10-28 18:15:12,116 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2013-10-28 18:15:12,130 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,130 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,140 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2013-10-28 18:15:12,157 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,158 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,178 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,178 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,179 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-28 18:15:12,179 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,180 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,180 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,181 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2013-10-28 18:15:12,193 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,241 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0013
2013-10-28 18:15:12,246 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,246 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,247 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,253 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,257 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,258 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2013-10-28 18:15:12,278 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0013_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,279 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,279 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0013_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,282 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0013_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-28 18:15:12,283 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,284 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0013_m_000000_0' done.
2013-10-28 18:15:12,293 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2013-10-28 18:15:12,301 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,310 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,313 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2013-10-28 18:15:12,320 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,321 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,324 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2013-10-28 18:15:12,333 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,334 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,358 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,362 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-28 18:15:12,363 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,364 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,366 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,369 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2013-10-28 18:15:12,377 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,396 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0014
2013-10-28 18:15:12,399 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,399 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,400 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,401 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,410 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,410 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2013-10-28 18:15:12,412 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0014_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,413 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,414 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0014_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,416 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-28 18:15:12,417 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,418 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0014_m_000000_0' done.
2013-10-28 18:15:12,427 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2013-10-28 18:15:12,434 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,443 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,444 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2013-10-28 18:15:12,451 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,452 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,466 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,466 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,472 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-28 18:15:12,472 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,472 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,478 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,479 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2013-10-28 18:15:12,497 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,537 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0015
2013-10-28 18:15:12,547 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,548 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,549 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,551 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,554 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,554 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2013-10-28 18:15:12,591 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0015_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,592 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,593 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0015_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,595 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0015_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-28 18:15:12,597 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,600 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0015_m_000000_0' done.
2013-10-28 18:15:12,610 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2013-10-28 18:15:12,619 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,632 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,633 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2013-10-28 18:15:12,641 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,642 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,652 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,653 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,653 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-28 18:15:12,653 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,653 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,653 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,654 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2013-10-28 18:15:12,666 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,691 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0016
2013-10-28 18:15:12,696 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,697 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,702 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,703 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,710 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,711 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,721 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2013-10-28 18:15:12,723 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0016_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,724 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,725 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0016_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,727 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-28 18:15:12,728 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,729 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0016_m_000000_0' done.
2013-10-28 18:15:12,733 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2013-10-28 18:15:12,740 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,748 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,749 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2013-10-28 18:15:12,756 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,756 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,768 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,769 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2013-10-28 18:15:12,781 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0017
2013-10-28 18:15:12,811 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,811 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,812 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,813 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2013-10-28 18:15:12,822 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0017_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,823 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,823 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0017_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,825 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-28 18:15:12,825 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,826 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0017_m_000000_0' done.
2013-10-28 18:15:12,831 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2013-10-28 18:15:12,843 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,851 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,856 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2013-10-28 18:15:12,871 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:12,872 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:12,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:12,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-28 18:15:12,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:12,883 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:12,884 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:12,884 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2013-10-28 18:15:12,892 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,923 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0018
2013-10-28 18:15:12,926 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:12,926 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:12,927 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:12,928 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:12,931 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:12,931 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:12,944 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:12,945 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2013-10-28 18:15:12,948 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0018_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:12,949 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:12,951 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0018_m_000000_0 is allowed to commit now
2013-10-28 18:15:12,953 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-28 18:15:12,954 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:12,956 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0018_m_000000_0' done.
2013-10-28 18:15:12,967 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2013-10-28 18:15:12,976 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,989 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:12,991 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2013-10-28 18:15:13,000 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,001 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,005 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2013-10-28 18:15:13,013 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,013 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,034 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,034 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,035 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-28 18:15:13,035 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,035 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,036 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,036 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2013-10-28 18:15:13,046 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,065 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0019
2013-10-28 18:15:13,074 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,074 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,075 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,077 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,082 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,092 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,093 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2013-10-28 18:15:13,102 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0019_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:13,103 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:13,103 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0019_m_000000_0 is allowed to commit now
2013-10-28 18:15:13,105 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0019_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-28 18:15:13,106 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:13,106 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0019_m_000000_0' done.
2013-10-28 18:15:13,116 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2013-10-28 18:15:13,140 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,169 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,176 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2013-10-28 18:15:13,192 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,202 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,263 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,264 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,265 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-28 18:15:13,265 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,266 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,267 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,269 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2013-10-28 18:15:13,278 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,322 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0020
2013-10-28 18:15:13,333 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,333 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,335 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,336 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,384 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,384 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2013-10-28 18:15:13,396 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0020_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:13,397 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:13,398 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0020_m_000000_0 is allowed to commit now
2013-10-28 18:15:13,399 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0020_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-28 18:15:13,412 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:13,413 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0020_m_000000_0' done.
2013-10-28 18:15:13,422 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2013-10-28 18:15:13,432 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,444 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,445 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2013-10-28 18:15:13,453 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,454 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-28 18:15:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,467 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,468 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,472 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-28 18:15:13,491 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,541 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0021
2013-10-28 18:15:13,552 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,552 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,553 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,554 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,562 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,570 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2013-10-28 18:15:13,570 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,575 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,577 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,583 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,592 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:13,592 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:13,593 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:13,593 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2013-10-28 18:15:13,593 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:13,594 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2013-10-28 18:15:13,594 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2013-10-28 18:15:13,610 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,613 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,621 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2013-10-28 18:15:13,639 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,640 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,664 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,665 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,666 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-28 18:15:13,667 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,667 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,668 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-28 18:15:13,678 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0022
2013-10-28 18:15:13,718 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,718 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,719 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,719 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,724 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,724 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,731 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2013-10-28 18:15:13,732 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,733 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,747 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,748 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,752 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:13,752 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:13,757 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:13,757 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2013-10-28 18:15:13,760 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:13,760 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutting down job executor
2013-10-28 18:15:13,764 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] shutdown complete
2013-10-28 18:15:13,764 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2013-10-28 18:15:13,764 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2013-10-28 18:15:13,777 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,778 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,798 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,798 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,798 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-28 18:15:13,799 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,800 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,800 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,801 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-28 18:15:13,811 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,835 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0023
2013-10-28 18:15:13,841 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,842 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,843 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,844 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,855 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2013-10-28 18:15:13,856 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,866 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,871 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,879 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_aroundBody2(MapTask.java:455)
	at org.apache.hadoop.mapred.MapTask$AjcClosure3.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.doPhaseCall(HadoopTaskAspect.java:166)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.ajc$inlineAccessMethod$com_intel_bigdata_management_agent_HadoopTaskAspect$com_intel_bigdata_management_agent_HadoopTaskAspect$doPhaseCall(HadoopTaskAspect.java:1)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundMap(HadoopTaskAspect.java:38)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:424)
	at org.apache.hadoop.mapred.MapTask.run_aroundBody0(MapTask.java:384)
	at org.apache.hadoop.mapred.MapTask$AjcClosure1.run(MapTask.java:1)
	at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149)
	at com.intel.bigdata.management.agent.HadoopTaskAspect.aroundTaskRun(HadoopTaskAspect.java:95)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:352)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2013-10-28 18:15:13,890 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events identify failed tasks
2013-10-28 18:15:13,890 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [every.every] task completion events count: 0
2013-10-28 18:15:13,891 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopping all jobs
2013-10-28 18:15:13,891 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2013-10-28 18:15:13,891 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] stopped all jobs
2013-10-28 18:15:13,891 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2013-10-28 18:15:13,892 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2013-10-28 18:15:13,900 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:13,901 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:13,917 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:13,917 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,917 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-28 18:15:13,917 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:13,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:13,918 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:13,918 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2013-10-28 18:15:13,926 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,948 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0024
2013-10-28 18:15:13,951 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:13,951 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:13,952 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:13,953 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:13,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:13,956 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:13,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:13,961 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2013-10-28 18:15:13,965 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0024_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:13,965 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:13,966 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0024_m_000000_0 is allowed to commit now
2013-10-28 18:15:13,968 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0024_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-28 18:15:13,969 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:13,969 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0024_m_000000_0' done.
2013-10-28 18:15:13,979 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2013-10-28 18:15:13,988 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,997 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:13,998 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2013-10-28 18:15:14,006 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,007 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,011 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2013-10-28 18:15:14,018 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,019 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,027 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-28 18:15:14,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,029 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2013-10-28 18:15:14,038 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,060 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0025
2013-10-28 18:15:14,063 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,063 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,064 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,065 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,072 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,072 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2013-10-28 18:15:14,074 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0025_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,075 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,078 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0025_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,088 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0025_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-28 18:15:14,089 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,090 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0025_m_000000_0' done.
2013-10-28 18:15:14,101 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2013-10-28 18:15:14,109 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,119 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,120 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2013-10-28 18:15:14,128 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,129 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,132 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2013-10-28 18:15:14,142 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,142 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,150 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,150 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,152 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-28 18:15:14,152 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,153 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,153 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,153 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2013-10-28 18:15:14,161 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,206 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0026
2013-10-28 18:15:14,213 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,213 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,215 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,216 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,224 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,230 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,247 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2013-10-28 18:15:14,251 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0026_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,258 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,259 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0026_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,262 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0026_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-28 18:15:14,268 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,269 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0026_m_000000_0' done.
2013-10-28 18:15:14,278 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2013-10-28 18:15:14,300 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,330 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,343 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2013-10-28 18:15:14,362 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,363 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,376 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,376 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,376 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-28 18:15:14,377 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,377 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,377 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,378 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2013-10-28 18:15:14,390 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0027
2013-10-28 18:15:14,425 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,427 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,428 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,429 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,439 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,439 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2013-10-28 18:15:14,442 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0027_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,442 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,443 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0027_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,445 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0027_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-28 18:15:14,446 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,446 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0027_m_000000_0' done.
2013-10-28 18:15:14,457 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2013-10-28 18:15:14,464 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,473 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,474 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2013-10-28 18:15:14,481 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,482 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,490 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,490 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,490 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-28 18:15:14,490 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,491 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,491 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2013-10-28 18:15:14,498 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,514 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0028
2013-10-28 18:15:14,518 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,518 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,519 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,520 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,522 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,522 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2013-10-28 18:15:14,529 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0028_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,530 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,530 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0028_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,532 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0028_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-28 18:15:14,532 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,533 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0028_m_000000_0' done.
2013-10-28 18:15:14,545 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2013-10-28 18:15:14,553 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,567 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,568 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2013-10-28 18:15:14,581 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,581 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,588 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,588 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,588 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-28 18:15:14,588 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,589 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,589 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,589 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2013-10-28 18:15:14,599 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,617 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0029
2013-10-28 18:15:14,623 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,624 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,625 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,626 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,629 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,629 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,641 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,641 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2013-10-28 18:15:14,644 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0029_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,645 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,645 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0029_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,647 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0029_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-28 18:15:14,648 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,648 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0029_m_000000_0' done.
2013-10-28 18:15:14,662 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2013-10-28 18:15:14,672 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,683 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,684 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2013-10-28 18:15:14,690 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,691 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,699 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,700 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,700 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-28 18:15:14,700 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,700 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,701 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2013-10-28 18:15:14,717 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,741 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0030
2013-10-28 18:15:14,744 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,744 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,744 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,745 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,755 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,755 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2013-10-28 18:15:14,758 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0030_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,758 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,759 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0030_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,764 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0030_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-28 18:15:14,764 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,765 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0030_m_000000_0' done.
2013-10-28 18:15:14,772 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2013-10-28 18:15:14,779 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,786 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,787 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2013-10-28 18:15:14,793 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,794 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,804 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every] starting
2013-10-28 18:15:14,805 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,805 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-28 18:15:14,805 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  parallel execution is enabled: false
2013-10-28 18:15:14,805 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  starting jobs: 1
2013-10-28 18:15:14,806 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [every.every]  allocating threads: 1
2013-10-28 18:15:14,806 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2013-10-28 18:15:14,814 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,838 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [every.every] submitted hadoop job: job_local_0031
2013-10-28 18:15:14,840 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 18:15:14,840 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:15:14,841 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt
2013-10-28 18:15:14,842 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:15:14,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:15:14,844 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:15:14,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt"]
2013-10-28 18:15:14,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2013-10-28 18:15:14,851 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0031_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:15:14,852 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 18:15:14,852 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0031_m_000000_0 is allowed to commit now
2013-10-28 18:15:14,854 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0031_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-28 18:15:14,855 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,855 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0031_m_000000_0' done.
2013-10-28 18:15:14,859 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2013-10-28 18:15:14,870 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,879 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:15:14,880 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2013-10-28 18:15:14,887 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:15:14,888 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:15:14,889 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/nums.20.txt:0+51
2013-10-28 18:15:14,893 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'