2013-10-28 18:09:58,514 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-28 18:09:58,535 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-28 18:09:58,536 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.function.FunctionPlatformTest
2013-10-28 18:09:58,560 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-28 18:09:58,820 INFO assembly.AggregateBy (AggregateBy.java:prepare(248)) - using threshold value: 2
2013-10-28 18:09:58,826 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(307)) - flushed keys num times: 1, with threshold: 2
2013-10-28 18:09:58,826 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(308)) - mem on flush (mb), free: 222, total: 254, max: 672
2013-10-28 18:09:58,827 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(313)) - total mem is 37% of max mem, to better utilize unused memory consider increasing current LRU threshold with system property "cascading.aggregateby.threshold"
2013-10-28 18:09:58,828 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(307)) - flushed keys num times: 3, with threshold: 2
2013-10-28 18:09:58,829 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(308)) - mem on flush (mb), free: 221, total: 254, max: 672
2013-10-28 18:09:58,830 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(313)) - total mem is 37% of max mem, to better utilize unused memory consider increasing current LRU threshold with system property "cascading.aggregateby.threshold"
2013-10-28 18:09:58,911 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:09:58,913 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:09:58,925 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: E1044ACB0D9A4D5AA26792BA42CA2C4E
2013-10-28 18:09:59,092 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-28 18:09:59,095 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] starting
2013-10-28 18:09:59,096 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] 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 18:09:59,096 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/formatter"]
2013-10-28 18:09:59,096 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] parallel execution is enabled: false
2013-10-28 18:09:59,097 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] starting jobs: 1
2013-10-28 18:09:59,097 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [formatter] allocating threads: 1
2013-10-28 18:09:59,100 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [formatter] starting step: (1/1) ...unctionplatform/formatter
2013-10-28 18:09:59,135 INFO util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(40)) - Trying to load the custom-built native-hadoop library...
2013-10-28 18:09:59,137 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(47)) - Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path
2013-10-28 18:09:59,138 ERROR util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(48)) - java.library.path=/usr/java/jdk1.6.0_31/jre/lib/amd64/server:/usr/java/jdk1.6.0_31/jre/lib/amd64:/usr/java/jdk1.6.0_31/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2013-10-28 18:09:59,138 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-28 18:09:59,196 ERROR snappy.LoadSnappy (LoadSnappy.java:<clinit>(51)) - Failed to load snappy with error: java.lang.UnsatisfiedLinkError: no snappy in java.library.path
2013-10-28 18:09:59,198 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(63)) - Snappy native library not loaded
2013-10-28 18:09:59,203 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:09:59,576 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [formatter] submitted hadoop job: job_local_0001
2013-10-28 18:09:59,661 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 18:09:59,662 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:09:59,669 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 18:09:59,675 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:09:59,684 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:09:59,685 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:09:59,730 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 18:09:59,731 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/formatter"]
2013-10-28 18:09:59,743 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:09:59,745 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 18:09:59,746 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-10-28 18:09:59,750 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/functionplatform/formatter
2013-10-28 18:09:59,751 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 18:09:59,752 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-28 18:09:59,761 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/functionplatform/formatter/_temporary
2013-10-28 18:09:59,783 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:09:59,808 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:09:59,810 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/functionplatform/formatter
2013-10-28 18:09:59,813 INFO assembly.AggregateBy (AggregateBy.java:prepare(248)) - using threshold value: 2
2013-10-28 18:09:59,813 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(307)) - flushed keys num times: 1, with threshold: 2
2013-10-28 18:09:59,814 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(308)) - mem on flush (mb), free: 193, total: 254, max: 672
2013-10-28 18:09:59,815 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(313)) - total mem is 37% of max mem, to better utilize unused memory consider increasing current LRU threshold with system property "cascading.aggregateby.threshold"
2013-10-28 18:09:59,815 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(307)) - flushed keys num times: 3, with threshold: 2
2013-10-28 18:09:59,817 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(308)) - mem on flush (mb), free: 193, total: 254, max: 672
2013-10-28 18:09:59,818 INFO assembly.AggregateBy (AggregateBy.java:removeEldestEntry(313)) - total mem is 37% of max mem, to better utilize unused memory consider increasing current LRU threshold with system property "cascading.aggregateby.threshold"
2013-10-28 18:09:59,846 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:09:59,848 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:09:59,887 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] starting
2013-10-28 18:09:59,888 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache.200.txt"]
2013-10-28 18:09:59,889 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/insert"]
2013-10-28 18:09:59,891 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] parallel execution is enabled: false
2013-10-28 18:09:59,903 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] starting jobs: 1
2013-10-28 18:09:59,904 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [apache] allocating threads: 1
2013-10-28 18:09:59,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [apache] starting step: (1/1) ...p/functionplatform/insert
2013-10-28 18:09:59,919 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:00,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [apache] submitted hadoop job: job_local_0002
2013-10-28 18:10:00,095 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 18:10:00,096 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:10:00,098 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 18:10:00,109 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 18:10:00,110 INFO mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 18:10:00,138 INFO mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 18:10:00,153 INFO mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 18:10:00,369 INFO mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 18:10:00,371 INFO mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 18:10:00,402 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:10:00,403 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:10:00,421 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.200.txt"]
2013-10-28 18:10:00,421 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: GroupBy(apache)[by:[{1}:'A']]
2013-10-28 18:10:00,460 INFO mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 18:10:00,478 INFO mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 18:10:00,488 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:10:00,493 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 18:10:00,494 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-28 18:10:00,505 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 18:10:00,505 INFO mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 18:10:00,515 INFO mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 18:10:00,516 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 18:10:00,522 INFO mapred.Merger (Merger.java:merge(424)) - Merging 1 sorted segments
2013-10-28 18:10:00,528 INFO mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 1 segments left of total size: 3402 bytes
2013-10-28 18:10:00,528 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 18:10:00,530 INFO mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 18:10:00,532 INFO hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 18:10:00,532 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 18:10:00,551 INFO hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: GroupBy(apache)[by:[{1}:'A']]
2013-10-28 18:10:00,551 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/functionplatform/insert"]
2013-10-28 18:10:00,582 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0002_r_000000_0 is done. And is in the process of commiting
2013-10-28 18:10:00,583 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 18:10:00,584 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0002_r_000000_0 is allowed to commit now
2013-10-28 18:10:00,587 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/insert
2013-10-28 18:10:00,588 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 18:10:00,589 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0002_r_000000_0' done.
2013-10-28 18:10:00,599 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/functionplatform/insert/_temporary
2013-10-28 18:10:00,629 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:00,674 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:00,689 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/functionplatform/insert
2013-10-28 18:10:00,722 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 18:10:00,723 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 18:10:00,763 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] starting
2013-10-28 18:10:00,764 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] 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 18:10:00,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/setvalue"]
2013-10-28 18:10:00,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] parallel execution is enabled: false
2013-10-28 18:10:00,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] starting jobs: 1
2013-10-28 18:10:00,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [setvalue] allocating threads: 1
2013-10-28 18:10:00,774 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [setvalue] starting step: (1/1) ...functionplatform/setvalue
2013-10-28 18:10:00,799 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:00,888 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [setvalue] submitted hadoop job: job_local_0003
2013-10-28 18:10:00,900 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : null
2013-10-28 18:10:00,901 INFO mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 18:10:00,903 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 18:10:00,904 INFO mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 0
2013-10-28 18:10:00,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 18:10:00,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 18:10:00,928 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 18:10:00,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/setvalue"]
2013-10-28 18:10:00,933 INFO mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-10-28 18:10:00,939 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-28 18:10:00,940 INFO mapred.Task (Task.java:commit(1006)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2013-10-28 18:10:00,943 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/functionplatform/setvalue
2013-10-28 18:10:00,950 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 18:10:00,951 INFO mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-28 18:10:00,960 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/functionplatform/setvalue/_temporary
2013-10-28 18:10:00,981 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:01,001 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 18:10:01,004 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/functionplatform/setvalue