2013-10-28 17:08:41,790 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-28 17:08:41,817 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-28 17:08:41,818 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.RegressionPipesPlatformTest
2013-10-28 17:08:41,852 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-28 17:08:42,448 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:42,464 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 17:08:42,497 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: ECFA255C159A48AAACEDA798662CD2C1
2013-10-28 17:08:42,899 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-28 17:08:42,902 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:42,902 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:42,903 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2013-10-28 17:08:42,903 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:42,903 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:42,904 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:42,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...regression/complexlogicor
2013-10-28 17:08:42,952 INFO util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(40)) - Trying to load the custom-built native-hadoop library...
2013-10-28 17:08:42,953 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 17:08:42,955 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 17:08:42,956 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 17:08:43,043 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 17:08:43,044 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(63)) - Snappy native library not loaded
2013-10-28 17:08:43,053 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:43,490 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0001
2013-10-28 17:08:43,582 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:43,584 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:43,591 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/lhs.txt
2013-10-28 17:08:43,599 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:43,610 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:43,611 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:43,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:43,681 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2013-10-28 17:08:43,698 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 17:08:43,704 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:43,705 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-10-28 17:08:43,710 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/regressionpipesplatform/regression/complexlogicor
2013-10-28 17:08:43,712 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt:0+52
2013-10-28 17:08:43,714 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-28 17:08:43,732 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/regressionpipesplatform/regression/complexlogicor/_temporary
2013-10-28 17:08:43,757 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:43,760 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/regressionpipesplatform/regression/complexlogicor
2013-10-28 17:08:43,788 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:43,790 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 17:08:43,822 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] starting
2013-10-28 17:08:43,823 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt"]
2013-10-28 17:08:43,825 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2013-10-28 17:08:43,825 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] parallel execution is enabled: false
2013-10-28 17:08:43,826 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] starting jobs: 1
2013-10-28 17:08:43,827 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] allocating threads: 1
2013-10-28 17:08:43,828 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [split] starting step: (1/1) ...ipesplatform/intermediate
2013-10-28 17:08:43,843 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:43,936 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [split] submitted hadoop job: job_local_0002
2013-10-28 17:08:43,949 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:43,949 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:43,950 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/lower.txt
2013-10-28 17:08:43,952 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:43,956 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:43,957 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:43,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt"]
2013-10-28 17:08:43,973 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2013-10-28 17:08:43,978 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 17:08:43,979 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:43,979 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-10-28 17:08:43,983 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/regressionpipesplatform/intermediate
2013-10-28 17:08:43,985 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt:0+19
2013-10-28 17:08:43,986 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-28 17:08:43,999 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/regressionpipesplatform/intermediate/_temporary
2013-10-28 17:08:44,026 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:44,027 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 17:08:44,067 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] starting
2013-10-28 17:08:44,068 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2013-10-28 17:08:44,068 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2013-10-28 17:08:44,069 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] parallel execution is enabled: false
2013-10-28 17:08:44,069 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] starting jobs: 1
2013-10-28 17:08:44,070 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs*rhs] allocating threads: 1
2013-10-28 17:08:44,070 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lhs*rhs] starting step: (1/1) ...ipesplatform/cogroupsplit
2013-10-28 17:08:44,084 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:44,183 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lhs*rhs] submitted hadoop job: job_local_0003
2013-10-28 17:08:44,194 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:44,194 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:44,196 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate/part-00000
2013-10-28 17:08:44,198 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:44,198 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:44,221 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:44,223 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:44,546 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:44,547 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:44,564 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:44,564 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:44,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2013-10-28 17:08:44,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2013-10-28 17:08:44,609 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:44,620 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:44,623 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 17:08:44,624 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/intermediate/part-00000:0+20
2013-10-28 17:08:44,625 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-28 17:08:44,641 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:44,641 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:44,650 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:44,650 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:44,655 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:44,663 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 162 bytes
2013-10-28 17:08:44,664 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:44,665 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:44,666 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:44,667 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:44,682 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2013-10-28 17:08:44,682 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2013-10-28 17:08:44,699 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:08:44,699 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:08:44,711 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:44,712 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:44,712 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0003_r_000000_0 is allowed to commit now
2013-10-28 17:08:44,716 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/cogroupsplit
2013-10-28 17:08:44,716 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:44,717 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0003_r_000000_0' done.
2013-10-28 17:08:44,725 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/regressionpipesplatform/cogroupsplit/_temporary
2013-10-28 17:08:44,735 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:44,752 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:44,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/regressionpipesplatform/cogroupsplit
2013-10-28 17:08:44,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/regressionpipesplatform/intermediate
2013-10-28 17:08:44,767 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:44,775 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 17:08:44,805 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:44,809 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:44,809 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2013-10-28 17:08:44,810 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:44,811 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:44,811 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:44,812 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ipesplatform/none-unknown
2013-10-28 17:08:44,824 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:44,861 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0004
2013-10-28 17:08:44,865 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:44,866 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:44,867 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/lower+upper.txt
2013-10-28 17:08:44,874 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:44,874 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:44,874 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:44,875 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:44,978 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:44,979 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:44,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:44,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:44,997 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/lower+upper.txt"]
2013-10-28 17:08:44,997 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2013-10-28 17:08:44,999 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:45,002 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:45,004 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 17:08:45,007 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:45,008 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0004_m_000000_0' done.
2013-10-28 17:08:45,012 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,013 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:45,014 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:45,014 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,015 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:45,017 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 147 bytes
2013-10-28 17:08:45,018 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,019 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:45,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:45,020 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,032 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2013-10-28 17:08:45,032 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2013-10-28 17:08:45,041 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0004_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:45,042 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,043 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0004_r_000000_0 is allowed to commit now
2013-10-28 17:08:45,046 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/none-unknown
2013-10-28 17:08:45,051 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:45,055 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0004_r_000000_0' done.
2013-10-28 17:08:45,067 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/regressionpipesplatform/none-unknown/_temporary
2013-10-28 17:08:45,088 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,094 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/regressionpipesplatform/none-unknown
2013-10-28 17:08:45,129 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:45,138 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 17:08:45,227 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:45,227 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.10.txt"]
2013-10-28 17:08:45,227 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/oomepre"]
2013-10-28 17:08:45,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:45,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:45,229 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:45,238 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...sionpipesplatform/oomepre
2013-10-28 17:08:45,262 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,289 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0005
2013-10-28 17:08:45,296 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,296 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:45,297 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/apache.10.txt
2013-10-28 17:08:45,298 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:45,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:45,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,308 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/apache.10.txt"]
2013-10-28 17:08:45,309 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/regressionpipesplatform/oomepre"]
2013-10-28 17:08:45,311 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught OutOfMemoryException, will not trap, rethrowing
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:593)
at cascading.TestFunction.operate(TestFunction.java:74)
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 17:08:45,313 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0005
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:593)
at cascading.TestFunction.operate(TestFunction.java:74)
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 17:08:45,317 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [test] task completion events identify failed tasks
2013-10-28 17:08:45,317 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [test] task completion events count: 0
2013-10-28 17:08:45,318 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] stopping all jobs
2013-10-28 17:08:45,318 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] stopping: (1/1) ...sionpipesplatform/oomepre
2013-10-28 17:08:45,319 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] stopped all jobs
2013-10-28 17:08:45,319 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] shutting down job executor
2013-10-28 17:08:45,321 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] shutdown complete
2013-10-28 17:08:45,321 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/regressionpipesplatform/oomepre/_temporary
exception = cascading.flow.FlowException: local step failed
2013-10-28 17:08:45,323 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/regressionpipesplatform/oomepre
2013-10-28 17:08:45,339 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:45,339 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 17:08:45,351 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:45,355 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:45,356 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/copy"]
2013-10-28 17:08:45,356 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:45,356 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:45,356 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:45,357 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ressionpipesplatform/copy
2013-10-28 17:08:45,371 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0006
2013-10-28 17:08:45,402 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,402 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:45,403 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/lower+upper.txt
2013-10-28 17:08:45,404 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:45,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:45,410 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,415 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/lower+upper.txt"]
2013-10-28 17:08:45,416 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/regressionpipesplatform/copy"]
2013-10-28 17:08:45,417 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 17:08:45,418 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,419 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2013-10-28 17:08:45,422 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/regressionpipesplatform/copy
2013-10-28 17:08:45,423 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:45,424 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0006_m_000000_0' done.
2013-10-28 17:08:45,429 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/regressionpipesplatform/copy/_temporary
2013-10-28 17:08:45,438 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,440 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/regressionpipesplatform/copy
2013-10-28 17:08:45,456 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:45,458 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 17:08:45,482 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:45,482 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:45,482 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2013-10-28 17:08:45,483 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:45,483 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:45,483 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:45,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...splatform/unknown-replace
2013-10-28 17:08:45,503 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,598 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0007
2013-10-28 17:08:45,602 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,602 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:45,603 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/lower+upper.txt
2013-10-28 17:08:45,605 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:45,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:45,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,620 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:45,620 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2013-10-28 17:08:45,622 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 17:08:45,623 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,624 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2013-10-28 17:08:45,626 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/regressionpipesplatform/unknown-replace
2013-10-28 17:08:45,627 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:45,628 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0007_m_000000_0' done.
2013-10-28 17:08:45,640 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/regressionpipesplatform/unknown-replace/_temporary
2013-10-28 17:08:45,654 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,667 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,669 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/regressionpipesplatform/unknown-replace
2013-10-28 17:08:45,686 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:45,693 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 17:08:45,711 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:45,711 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:45,712 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2013-10-28 17:08:45,712 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:45,712 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:45,713 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:45,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...egression/complexlogicand
2013-10-28 17:08:45,724 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,770 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0008
2013-10-28 17:08:45,779 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,780 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:45,781 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/lhs.txt
2013-10-28 17:08:45,784 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:45,787 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:45,793 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:45,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2013-10-28 17:08:45,812 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 17:08:45,814 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,815 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-10-28 17:08:45,819 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/regressionpipesplatform/regression/complexlogicand
2013-10-28 17:08:45,820 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt:0+52
2013-10-28 17:08:45,821 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0008_m_000000_0' done.
2013-10-28 17:08:45,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/regressionpipesplatform/regression/complexlogicand/_temporary
2013-10-28 17:08:45,841 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,843 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/regressionpipesplatform/regression/complexlogicand
2013-10-28 17:08:45,855 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:45,856 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 17:08:45,903 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:45,904 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:45,905 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2013-10-28 17:08:45,906 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:45,907 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:45,907 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:45,909 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...egression/complexlogicxor
2013-10-28 17:08:45,926 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:45,962 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0009
2013-10-28 17:08:45,967 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:45,967 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:45,969 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/lhs.txt
2013-10-28 17:08:45,970 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:45,973 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:45,973 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:45,986 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt"]
2013-10-28 17:08:45,987 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2013-10-28 17:08:45,989 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 17:08:45,989 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:45,990 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0009_m_000000_0 is allowed to commit now
2013-10-28 17:08:45,992 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/regressionpipesplatform/regression/complexlogicxor
2013-10-28 17:08:45,993 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lhs.txt:0+52
2013-10-28 17:08:45,994 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0009_m_000000_0' done.
2013-10-28 17:08:46,004 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/regressionpipesplatform/regression/complexlogicxor/_temporary
2013-10-28 17:08:46,014 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:46,015 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/regressionpipesplatform/regression/complexlogicxor
2013-10-28 17:08:46,034 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:46,040 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 17:08:46,090 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting
2013-10-28 17:08:46,091 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/upper.txt"]
2013-10-28 17:08:46,092 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt"]
2013-10-28 17:08:46,093 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2013-10-28 17:08:46,093 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] parallel execution is enabled: false
2013-10-28 17:08:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] starting jobs: 1
2013-10-28 17:08:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] allocating threads: 1
2013-10-28 17:08:46,100 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] starting step: (1/1) ...ionpipesplatform/oomepost
2013-10-28 17:08:46,116 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:46,124 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:46,207 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] submitted hadoop job: job_local_0010
2013-10-28 17:08:46,228 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:46,231 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:46,233 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/upper.txt
2013-10-28 17:08:46,235 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:46,238 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:46,239 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:46,239 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:46,532 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:46,534 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:46,535 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:46,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:46,552 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/upper.txt"]
2013-10-28 17:08:46,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2013-10-28 17:08:46,561 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:46,563 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:46,566 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0010_m_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:46,567 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/upper.txt:0+19
2013-10-28 17:08:46,569 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0010_m_000000_0' done.
2013-10-28 17:08:46,570 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:46,570 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:46,571 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/lower.txt
2013-10-28 17:08:46,572 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:46,572 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:46,573 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:46,573 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:46,688 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:46,688 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:46,689 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:46,689 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:46,699 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/lower.txt"]
2013-10-28 17:08:46,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2013-10-28 17:08:46,701 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:46,735 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:46,736 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0010_m_000001_0 is done. And is in the process of commiting
2013-10-28 17:08:46,738 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt:0+19
2013-10-28 17:08:46,738 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0010_m_000001_0' done.
2013-10-28 17:08:46,744 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:46,744 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:46,745 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:46,745 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:46,747 INFO mapred.Merger (Merger.java:merge(424)) - Merging 2 sorted segments
2013-10-28 17:08:46,755 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2013-10-28 17:08:46,756 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:46,757 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:46,757 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:46,757 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:46,765 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2013-10-28 17:08:46,765 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2013-10-28 17:08:46,769 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:08:46,772 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:08:46,773 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught OutOfMemoryException, will not trap, rethrowing
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:643)
at cascading.TestFunction.operate(TestFunction.java:74)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:45)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:90)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:133)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer_aroundBody2(ReduceTask.java:573)
at org.apache.hadoop.mapred.ReduceTask$AjcClosure3.run(ReduceTask.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.aroundReduce(HadoopTaskAspect.java:43)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:539)
at org.apache.hadoop.mapred.ReduceTask.run_aroundBody0(ReduceTask.java:474)
at org.apache.hadoop.mapred.ReduceTask$AjcClosure1.run(ReduceTask.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.ReduceTask.run(ReduceTask.java:359)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2013-10-28 17:08:46,775 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:643)
at cascading.TestFunction.operate(TestFunction.java:74)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:45)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:90)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:133)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer_aroundBody2(ReduceTask.java:573)
at org.apache.hadoop.mapred.ReduceTask$AjcClosure3.run(ReduceTask.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.aroundReduce(HadoopTaskAspect.java:43)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:539)
at org.apache.hadoop.mapred.ReduceTask.run_aroundBody0(ReduceTask.java:474)
at org.apache.hadoop.mapred.ReduceTask$AjcClosure1.run(ReduceTask.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.ReduceTask.run(ReduceTask.java:359)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2013-10-28 17:08:46,782 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [lower*upper] task completion events identify failed tasks
2013-10-28 17:08:46,782 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [lower*upper] task completion events count: 0
2013-10-28 17:08:46,783 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] stopping all jobs
2013-10-28 17:08:46,783 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lower*upper] stopping: (1/1) ...ionpipesplatform/oomepost
2013-10-28 17:08:46,786 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lower*upper] stopped all jobs
2013-10-28 17:08:46,786 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/regressionpipesplatform/oomepost/_temporary
exception = cascading.flow.FlowException: local step failed
2013-10-28 17:08:46,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/regressionpipesplatform/oomepost
2013-10-28 17:08:46,795 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:46,795 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 17:08:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.10.txt"]
2013-10-28 17:08:46,820 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2013-10-28 17:08:46,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:46,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:46,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:46,826 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...platform/lasteachmodified
2013-10-28 17:08:46,835 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:46,854 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0011
2013-10-28 17:08:46,860 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:46,861 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:46,863 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/apache.10.txt
2013-10-28 17:08:46,864 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:46,865 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:46,866 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:46,866 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:46,970 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:46,970 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:46,971 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:46,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:46,977 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/apache.10.txt"]
2013-10-28 17:08:46,977 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2013-10-28 17:08:46,979 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:46,981 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:46,982 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0011_m_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:46,984 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.10.txt:0+1449
2013-10-28 17:08:46,984 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0011_m_000000_0' done.
2013-10-28 17:08:46,987 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:46,987 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:46,987 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:46,988 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:46,989 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:46,989 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 182 bytes
2013-10-28 17:08:46,989 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:46,990 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:46,990 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:46,990 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:47,002 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2013-10-28 17:08:47,004 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2013-10-28 17:08:47,008 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0011_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:47,009 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:47,009 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0011_r_000000_0 is allowed to commit now
2013-10-28 17:08:47,011 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0011_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/lasteachmodified
2013-10-28 17:08:47,012 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:47,013 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0011_r_000000_0' done.
2013-10-28 17:08:47,021 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/regressionpipesplatform/lasteachmodified/_temporary
2013-10-28 17:08:47,035 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:47,037 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/regressionpipesplatform/lasteachmodified
2013-10-28 17:08:47,046 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:47,047 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 17:08:47,065 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:47,065 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:47,066 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/unknown"]
2013-10-28 17:08:47,066 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:47,067 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:47,067 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:47,068 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...sionpipesplatform/unknown
2013-10-28 17:08:47,077 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:47,140 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0012
2013-10-28 17:08:47,143 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:47,144 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:47,146 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/lower+upper.txt
2013-10-28 17:08:47,147 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:47,156 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:47,159 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:47,165 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/lower+upper.txt"]
2013-10-28 17:08:47,166 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/regressionpipesplatform/unknown"]
2013-10-28 17:08:47,168 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0012_m_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:47,168 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:47,169 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0012_m_000000_0 is allowed to commit now
2013-10-28 17:08:47,171 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0012_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/unknown
2013-10-28 17:08:47,171 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:47,172 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0012_m_000000_0' done.
2013-10-28 17:08:47,176 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/regressionpipesplatform/unknown/_temporary
2013-10-28 17:08:47,196 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:47,202 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/regressionpipesplatform/unknown
2013-10-28 17:08:47,220 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:47,224 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 17:08:47,264 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:47,265 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/critics.txt"]
2013-10-28 17:08:47,266 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/varwidth"]
2013-10-28 17:08:47,266 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:47,267 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:47,267 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:47,274 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...ionpipesplatform/varwidth
2013-10-28 17:08:47,322 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:47,407 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0013
2013-10-28 17:08:47,419 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:47,419 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:47,420 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/critics.txt
2013-10-28 17:08:47,422 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:47,428 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:47,438 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:47,450 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/critics.txt"]
2013-10-28 17:08:47,451 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/regressionpipesplatform/varwidth"]
2013-10-28 17:08:47,453 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 17:08:47,454 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:47,455 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0013_m_000000_0 is allowed to commit now
2013-10-28 17:08:47,473 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/regressionpipesplatform/varwidth
2013-10-28 17:08:47,474 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/critics.txt:0+828
2013-10-28 17:08:47,475 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0013_m_000000_0' done.
2013-10-28 17:08:47,479 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/regressionpipesplatform/varwidth/_temporary
2013-10-28 17:08:47,494 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:47,496 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/regressionpipesplatform/varwidth
2013-10-28 17:08:47,908 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:47,908 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 17:08:49,786 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] starting
2013-10-28 17:08:49,786 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] source: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.200.txt"]
2013-10-28 17:08:49,787 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2013-10-28 17:08:49,788 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] parallel execution is enabled: false
2013-10-28 17:08:49,788 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] starting jobs: 1
2013-10-28 17:08:49,788 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipeline] allocating threads: 1
2013-10-28 17:08:49,789 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipeline] starting step: (1/1) ...pipesplatform/deeppipline
2013-10-28 17:08:49,797 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:49,842 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipeline] submitted hadoop job: job_local_0014
2013-10-28 17:08:49,845 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:49,845 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:49,846 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/apache.200.txt
2013-10-28 17:08:49,847 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:49,847 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:49,848 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:49,848 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:49,910 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:49,911 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:49,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:49,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:50,323 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.200.txt"]
2013-10-28 17:08:50,324 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2013-10-28 17:08:50,594 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:50,610 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:50,611 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 17:08:50,613 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.200.txt:0+32599
2013-10-28 17:08:50,613 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0014_m_000000_0' done.
2013-10-28 17:08:50,616 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:50,617 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:50,617 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:50,617 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:50,619 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:50,620 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 35984 bytes
2013-10-28 17:08:50,620 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:50,621 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:50,621 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:50,622 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:50,742 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2013-10-28 17:08:50,743 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2013-10-28 17:08:51,308 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.10.txt:0+1449
2013-10-28 17:08:51,358 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0014_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:51,360 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,361 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0014_r_000000_0 is allowed to commit now
2013-10-28 17:08:51,367 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0014_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/deeppipline
2013-10-28 17:08:51,375 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:51,376 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0014_r_000000_0' done.
2013-10-28 17:08:51,386 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/regressionpipesplatform/deeppipline/_temporary
2013-10-28 17:08:51,386 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/regressionpipesplatform/deeppipline
2013-10-28 17:08:51,399 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:51,400 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 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] starting
2013-10-28 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt"]
2013-10-28 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2013-10-28 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] parallel execution is enabled: false
2013-10-28 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] starting jobs: 1
2013-10-28 17:08:51,472 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [split] allocating threads: 1
2013-10-28 17:08:51,480 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [split] starting step: (1/1) ...latform/splitintermediate
2013-10-28 17:08:51,489 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:51,532 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [split] submitted hadoop job: job_local_0015
2013-10-28 17:08:51,543 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:51,544 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:51,545 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/lower.txt
2013-10-28 17:08:51,546 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:51,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:51,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:51,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt"]
2013-10-28 17:08:51,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2013-10-28 17:08:51,560 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 17:08:51,561 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,562 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0015_m_000000_0 is allowed to commit now
2013-10-28 17:08:51,563 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/regressionpipesplatform/splitintermediate
2013-10-28 17:08:51,564 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower.txt:0+19
2013-10-28 17:08:51,564 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0015_m_000000_0' done.
2013-10-28 17:08:51,576 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/regressionpipesplatform/splitintermediate/_temporary
2013-10-28 17:08:51,583 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:51,584 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 17:08:51,617 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] starting
2013-10-28 17:08:51,617 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2013-10-28 17:08:51,617 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2013-10-28 17:08:51,617 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] parallel execution is enabled: false
2013-10-28 17:08:51,617 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] starting jobs: 1
2013-10-28 17:08:51,618 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [lhs+rhs] allocating threads: 1
2013-10-28 17:08:51,625 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lhs+rhs] starting step: (1/1) ...ipesplatform/groupbysplit
2013-10-28 17:08:51,646 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:51,678 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [lhs+rhs] submitted hadoop job: job_local_0016
2013-10-28 17:08:51,695 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:51,696 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:51,696 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate/part-00000
2013-10-28 17:08:51,697 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:51,698 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:51,698 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:51,698 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:51,717 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:51,718 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:51,719 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:51,719 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:51,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2013-10-28 17:08:51,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2013-10-28 17:08:51,725 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:51,727 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:51,728 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 17:08:51,729 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/splitintermediate/part-00000:0+20
2013-10-28 17:08:51,729 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0016_m_000000_0' done.
2013-10-28 17:08:51,732 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:51,732 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:51,733 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:51,733 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,734 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:51,734 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 172 bytes
2013-10-28 17:08:51,734 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,735 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:51,735 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:51,735 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:51,739 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2013-10-28 17:08:51,739 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2013-10-28 17:08:51,743 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0016_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:51,743 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,744 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0016_r_000000_0 is allowed to commit now
2013-10-28 17:08:51,746 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0016_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/groupbysplit
2013-10-28 17:08:51,746 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:51,747 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0016_r_000000_0' done.
2013-10-28 17:08:51,753 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/regressionpipesplatform/groupbysplit/_temporary
2013-10-28 17:08:51,761 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:51,772 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:51,773 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/regressionpipesplatform/groupbysplit
2013-10-28 17:08:51,774 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/regressionpipesplatform/splitintermediate
2013-10-28 17:08:51,783 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:51,783 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 17:08:51,820 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] starting
2013-10-28 17:08:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2013-10-28 17:08:51,821 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] parallel execution is enabled: false
2013-10-28 17:08:51,822 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] starting jobs: 2
2013-10-28 17:08:51,822 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [**&%&%bar:bar@foo://bl...] allocating threads: 1
2013-10-28 17:08:51,823 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2013-10-28 17:08:51,847 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:51,901 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0017
2013-10-28 17:08:51,907 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:51,908 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:51,908 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/lower+upper.txt
2013-10-28 17:08:51,909 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:51,909 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:51,914 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:51,914 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:51,970 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:51,971 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:51,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:51,972 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:51,976 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/lower+upper.txt"]
2013-10-28 17:08:51,976 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2013-10-28 17:08:51,979 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:51,981 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:51,982 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 17:08:51,983 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:51,984 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0017_m_000000_0' done.
2013-10-28 17:08:51,987 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:51,987 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:51,988 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:08:51,988 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,989 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:51,989 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 77 bytes
2013-10-28 17:08:51,989 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:51,992 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:51,993 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:51,993 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:51,996 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2013-10-28 17:08:51,997 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][4245215274/__&%&%bar:bar@foo:_blah_/]
2013-10-28 17:08:52,007 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0017_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:52,007 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:52,010 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0017_r_000000_0 is allowed to commit now
2013-10-28 17:08:52,011 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0017_r_000000_0' to file:/tmp/hadoop-root/4245215274____bar_bar_foo__blah__A81204D6A10D429890F312DC750F6446
2013-10-28 17:08:52,012 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:52,012 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0017_r_000000_0' done.
2013-10-28 17:08:52,020 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...ipesplatform/illegalchars
2013-10-28 17:08:52,027 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:52,053 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0018
2013-10-28 17:08:52,056 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:52,056 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:52,057 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-root/4245215274____bar_bar_foo__blah__A81204D6A10D429890F312DC750F6446/part-00000
2013-10-28 17:08:52,064 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:08:52,064 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:08:52,064 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:08:52,065 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:08:52,097 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:08:52,098 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:08:52,101 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:52,101 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:52,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][4245215274/__&%&%bar:bar@foo:_blah_/]
2013-10-28 17:08:52,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2013-10-28 17:08:52,106 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:08:52,108 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:08:52,110 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 17:08:52,111 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/tmp/hadoop-root/4245215274____bar_bar_foo__blah__A81204D6A10D429890F312DC750F6446/part-00000:0+170
2013-10-28 17:08:52,112 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0018_m_000000_0' done.
2013-10-28 17:08:52,120 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:52,120 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:08:52,120 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=549584896, MaxSingleShuffleLimit=137396224
2013-10-28 17:08:52,121 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:52,122 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 17:08:52,123 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 77 bytes
2013-10-28 17:08:52,123 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:52,123 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:08:52,124 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:08:52,124 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:08:52,127 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2013-10-28 17:08:52,128 INFO hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2013-10-28 17:08:52,142 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0018_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:08:52,142 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:52,143 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0018_r_000000_0 is allowed to commit now
2013-10-28 17:08:52,149 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0018_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/illegalchars
2013-10-28 17:08:52,152 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:08:52,152 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0018_r_000000_0' done.
2013-10-28 17:08:52,169 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/regressionpipesplatform/illegalchars/_temporary
2013-10-28 17:08:52,180 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:52,189 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/regressionpipesplatform/illegalchars
2013-10-28 17:08:52,211 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:08:52,212 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 17:08:52,258 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting
2013-10-28 17:08:52,259 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt"]
2013-10-28 17:08:52,260 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2013-10-28 17:08:52,260 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] parallel execution is enabled: false
2013-10-28 17:08:52,261 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] starting jobs: 1
2013-10-28 17:08:52,261 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [test] allocating threads: 1
2013-10-28 17:08:52,274 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2013-10-28 17:08:52,322 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:52,439 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [test] submitted hadoop job: job_local_0019
2013-10-28 17:08:52,467 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 17:08:52,469 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:08:52,470 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/lower+upper.txt
2013-10-28 17:08:52,472 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 17:08:52,479 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:08:52,480 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:08:52,486 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/lower+upper.txt"]
2013-10-28 17:08:52,487 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/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2013-10-28 17:08:52,489 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 17:08:52,494 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 17:08:52,494 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0019_m_000000_0 is allowed to commit now
2013-10-28 17:08:52,496 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/regressionpipesplatform/ungrouped-unknown-nondeterministic
2013-10-28 17:08:52,497 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/lower+upper.txt:0+30
2013-10-28 17:08:52,497 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0019_m_000000_0' done.
2013-10-28 17:08:52,504 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/regressionpipesplatform/ungrouped-unknown-nondeterministic/_temporary
2013-10-28 17:08:52,514 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:08:52,522 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/regressionpipesplatform/ungrouped-unknown-nondeterministic