Class cascading.TypedFieldedPipesPlatformTest

12

tests

0

failures

2.921s

duration

100%

successful

Tests

Test Duration Result
testCoGroupComparableTypes 0.145s passed
testCoGroupComparableTypesDeclared 0.052s passed
testCoGroupIncomparableTypes 0.079s passed
testCoGroupIncomparableTypesDeclared 0.039s passed
testFieldTypeCheck 1.761s passed
testGroupByComparableTypes 0.065s passed
testGroupByIncomparableTypes 0.024s passed
testHashJoinComparableTypes 0.062s passed
testHashJoinComparableTypesDeclared 0.122s passed
testHashJoinIncomparableTypes 0.438s passed
testHashJoinIncomparableTypesDeclared 0.092s passed
testMergeIncomparableTypes 0.042s passed

Standard output

2013-10-28 17:41:54,188 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-28 17:41:54,272 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-28 17:41:54,282 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.TypedFieldedPipesPlatformTest
2013-10-28 17:41:54,341 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-28 17:41:54,678 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:54,690 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:41:54,709 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 2186433880BD4D71AC8893EA1FA263EE
2013-10-28 17:41:54,775 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/typedfieldedpipesplatform/testHashJoinIncomparableTypes
2013-10-28 17:41:54,840 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:54,841 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:41:54,855 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/typedfieldedpipesplatform/testCoGroupIncomparableTypes
2013-10-28 17:41:54,886 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:54,887 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:41:54,999 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/typedfieldedpipesplatform/testCoGroupComparableTypes
2013-10-28 17:41:55,028 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,030 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:41:55,040 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/typedfieldedpipesplatform/testCoGroupIncomparableTypesDeclared
2013-10-28 17:41:55,066 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,068 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /root/.gradle/caches/artifacts-26/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-10-28 17:41:55,093 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/typedfieldedpipesplatform/testCoGroupComparableTypesDeclared
2013-10-28 17:41:55,124 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,131 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:41:55,156 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/typedfieldedpipesplatform/testHashJoinComparableTypes
2013-10-28 17:41:55,181 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,183 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:41:55,213 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/typedfieldedpipesplatform/testGroupByComparableTypes
2013-10-28 17:41:55,283 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,290 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:41:55,312 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/typedfieldedpipesplatform/testHashJoinIncomparableTypesDeclared
2013-10-28 17:41:55,384 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,398 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:41:55,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/typedfieldedpipesplatform/testHashJoinComparableTypesDeclared
2013-10-28 17:41:55,471 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,472 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:41:55,483 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/typedfieldedpipesplatform/testMergeIncomparableTypes
2013-10-28 17:41:55,728 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:55,731 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:41:55,834 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-10-28 17:41:55,840 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [] starting
2013-10-28 17:41:55,842 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, Long, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt"]
2013-10-28 17:41:55,843 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt"]
2013-10-28 17:41:55,844 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  sink: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na', 10:19 | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String, String, String, String, Long, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck"]
2013-10-28 17:41:55,845 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  parallel execution is enabled: false
2013-10-28 17:41:55,846 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  starting jobs: 1
2013-10-28 17:41:55,847 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - []  allocating threads: 1
2013-10-28 17:41:55,856 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [] starting step: (1/1) ...atform/testFieldTypeCheck
2013-10-28 17:41:55,934 INFO  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(40)) - Trying to load the custom-built native-hadoop library...
2013-10-28 17:41:55,936 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:41:55,937 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:41:55,938 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:41:56,006 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:41:56,013 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(63)) - Snappy native library not loaded
2013-10-28 17:41:56,020 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:41:56,037 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:41:56,331 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [] submitted hadoop job: job_local_0001
2013-10-28 17:41:56,447 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 17:41:56,448 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:41:56,454 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-clean.10.txt
2013-10-28 17:41:56,462 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:41:56,463 INFO  mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:41:56,470 INFO  mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:41:56,472 INFO  mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:41:56,598 INFO  mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:41:56,599 INFO  mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:41:56,620 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:41:56,620 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:41:56,679 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt"]
2013-10-28 17:41:56,680 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2013-10-28 17:41:56,821 INFO  mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:41:56,832 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:41:56,834 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:41:56,837 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt:0+1449
2013-10-28 17:41:56,838 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-28 17:41:56,840 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 17:41:56,840 INFO  mapred.TaskDelegation (TaskDelegation.java:getMapTaskDelegator(83)) - MapTaskDelegator is not defined
2013-10-28 17:41:56,841 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt
2013-10-28 17:41:56,842 INFO  mapred.MapTask (MapTask.java:runOldMapper_aroundBody2(437)) - numReduceTasks: 1
2013-10-28 17:41:56,843 INFO  mapred.TaskDelegation (TaskDelegation.java:getOutputCollectorDelegator(142)) - MapOutputCollectorDelegator not found
2013-10-28 17:41:56,848 INFO  mapred.MapTask (MapTask.java:<init>(998)) - Sort avoidance is turn off
2013-10-28 17:41:56,849 INFO  mapred.MapTask (MapTask.java:<init>(1021)) - io.sort.mb = 100
2013-10-28 17:41:56,962 INFO  mapred.MapTask (MapTask.java:<init>(1033)) - data buffer = 79691776/99614720
2013-10-28 17:41:56,963 INFO  mapred.MapTask (MapTask.java:<init>(1034)) - record buffer = 262144/327680
2013-10-28 17:41:56,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-10-28 17:41:56,964 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-28 17:41:56,987 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, Long, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt"]
2013-10-28 17:41:56,988 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2013-10-28 17:41:56,999 INFO  mapred.MapTask (MapTask.java:flush(1367)) - Starting flush of map output
2013-10-28 17:41:57,002 INFO  mapred.MapTask (MapTask.java:sortAndSpill(1560)) - Finished spill 0
2013-10-28 17:41:57,004 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0001_m_000001_0 is done. And is in the process of commiting
2013-10-28 17:41:57,006 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/classes/test/data/apache-clean.10.txt:0+1449
2013-10-28 17:41:57,007 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_m_000001_0' done.
2013-10-28 17:41:57,020 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : null
2013-10-28 17:41:57,020 INFO  mapred.ReduceTask (ReduceTask.java:run_aroundBody0(393)) - Sort avoidance is turned off
2013-10-28 17:41:57,028 INFO  mapred.ReduceTask (ReduceTask.java:<init>(1174)) - ShuffleRamManager: MemoryLimit=493250144, MaxSingleShuffleLimit=123312536
2013-10-28 17:41:57,029 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 17:41:57,034 INFO  mapred.Merger (Merger.java:merge(424)) - Merging 2 sorted segments
2013-10-28 17:41:57,039 INFO  mapred.Merger (Merger.java:merge(507)) - Down to the last merge-pass, with 2 segments left of total size: 3010 bytes
2013-10-28 17:41:57,040 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 17:41:57,041 INFO  mapred.TaskDelegation (TaskDelegation.java:getReduceTaskDelegator(112)) - Reduce task Delegator not defined
2013-10-28 17:41:57,042 INFO  hadoop.FlowReducer (FlowReducer.java:configure(77)) - cascading version: 2.2.0
2013-10-28 17:41:57,042 INFO  hadoop.FlowReducer (FlowReducer.java:configure(78)) - child jvm opts: -Xmx200m
2013-10-28 17:41:57,073 INFO  hadoop.FlowReducer (FlowReducer.java:configure(96)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'date'] rhs:[{1}:'date']]
2013-10-28 17:41:57,075 INFO  hadoop.FlowReducer (FlowReducer.java:configure(99)) - sinking to: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na', 10:19 | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String, String, String, String, Long, String, int, long, String, String, String]]"]["/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck"]
2013-10-28 17:41:57,105 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:41:57,106 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2013-10-28 17:41:57,142 INFO  mapred.Task (Task.java:done_aroundBody0(853)) - Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting
2013-10-28 17:41:57,152 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - 
2013-10-28 17:41:57,152 INFO  mapred.Task (Task.java:commit(1006)) - Task attempt_local_0001_r_000000_0 is allowed to commit now
2013-10-28 17:41:57,156 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_r_000000_0' to file:/root/cascading/cascading.compatibility-2.2/intel-hadoop-2.5.1/build/test/output/hadoop/typedfieldedpipesplatform/testFieldTypeCheck
2013-10-28 17:41:57,165 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - reduce > reduce
2013-10-28 17:41:57,166 INFO  mapred.Task (Task.java:sendDone(965)) - Task 'attempt_local_0001_r_000000_0' done.
2013-10-28 17:41:57,200 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/typedfieldedpipesplatform/testFieldTypeCheck/_temporary
2013-10-28 17:41:57,218 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-28 17:41:57,244 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/typedfieldedpipesplatform/testFieldTypeCheck
2013-10-28 17:41:57,261 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-28 17:41:57,263 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:41:57,269 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/typedfieldedpipesplatform/testGroupByIncomparableTypes