Class cascading.function.FunctionPlatformTest

5

tests

0

failures

2.442s

duration

100%

successful

Tests

Test Duration Result
testFieldFormatter 0.978s passed
testInsert 0.870s passed
testPartialCounts 0.273s passed
testPartialSums 0.006s passed
testSetValue 0.315s passed

Standard output

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