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'