2014-08-22 17:28:10,293 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2014-08-22 17:28:10,341 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2014-08-22 17:28:10,341 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.RegressionPipesPlatformTest
2014-08-22 17:28:10,376 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2014-08-22 17:28:10,802 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:10,805 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:10,817 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 3849C45E16C042D1B7B98ADA3EBB0CCA
2014-08-22 17:28:11,041 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.5.6
2014-08-22 17:28:11,044 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:11,045 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:11,046 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2014-08-22 17:28:11,046 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:11,046 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:11,047 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:11,049 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...regression/complexlogicor
2014-08-22 17:28:11,100 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-08-22 17:28:11,179 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2014-08-22 17:28:11,183 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:11,426 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1134863947_0001
2014-08-22 17:28:11,427 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:11,460 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:11,463 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1134863947_0001_m_000000_0
2014-08-22 17:28:11,522 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2014-08-22 17:28:11,529 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@ba8402c
2014-08-22 17:28:11,544 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt
2014-08-22 17:28:11,545 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2182a70
2014-08-22 17:28:11,553 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:11,565 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:11,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:11,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:11,624 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2014-08-22 17:28:11,640 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1134863947_0001_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:11,645 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:11,646 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1134863947_0001_m_000000_0 is allowed to commit now
2014-08-22 17:28:11,652 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1134863947_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor
2014-08-22 17:28:11,654 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt:0+52
2014-08-22 17:28:11,655 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1134863947_0001_m_000000_0' done.
2014-08-22 17:28:11,655 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1134863947_0001_m_000000_0
2014-08-22 17:28:11,656 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:11,674 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor/_temporary
2014-08-22 17:28:11,701 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:11,704 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicor
2014-08-22 17:28:11,733 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:11,734 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:11,760 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] starting
2014-08-22 17:28:11,760 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:11,761 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2014-08-22 17:28:11,762 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] parallel execution is enabled: false
2014-08-22 17:28:11,762 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] starting jobs: 1
2014-08-22 17:28:11,762 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] allocating threads: 1
2014-08-22 17:28:11,764 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] starting step: (1/1) ...ipesplatform/intermediate
2014-08-22 17:28:11,782 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:11,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] submitted hadoop job: job_local508684308_0002
2014-08-22 17:28:11,887 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] tracking url: http://localhost:8080/
2014-08-22 17:28:11,889 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:11,890 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local508684308_0002_m_000000_0
2014-08-22 17:28:11,892 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1cad7d80
2014-08-22 17:28:11,894 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt
2014-08-22 17:28:11,894 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1bb0889a
2014-08-22 17:28:11,896 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:11,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:11,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:11,916 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:11,916 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2014-08-22 17:28:11,919 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local508684308_0002_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:11,921 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:11,922 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local508684308_0002_m_000000_0 is allowed to commit now
2014-08-22 17:28:11,926 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local508684308_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate
2014-08-22 17:28:11,928 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt:0+19
2014-08-22 17:28:11,928 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local508684308_0002_m_000000_0' done.
2014-08-22 17:28:11,928 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local508684308_0002_m_000000_0
2014-08-22 17:28:11,928 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:11,939 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate/_temporary
2014-08-22 17:28:11,967 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:11,968 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:12,017 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] starting
2014-08-22 17:28:12,017 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2014-08-22 17:28:12,017 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2014-08-22 17:28:12,018 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] parallel execution is enabled: false
2014-08-22 17:28:12,018 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] starting jobs: 1
2014-08-22 17:28:12,018 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs*rhs] allocating threads: 1
2014-08-22 17:28:12,018 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs*rhs] starting step: (1/1) ...ipesplatform/cogroupsplit
2014-08-22 17:28:12,036 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs*rhs] submitted hadoop job: job_local558630407_0003
2014-08-22 17:28:12,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs*rhs] tracking url: http://localhost:8080/
2014-08-22 17:28:12,101 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:12,102 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local558630407_0003_m_000000_0
2014-08-22 17:28:12,104 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@58d51a54
2014-08-22 17:28:12,106 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate/part-00000
2014-08-22 17:28:12,106 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@40537935
2014-08-22 17:28:12,108 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:12,116 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:12,253 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:12,253 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:12,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:12,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:12,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2014-08-22 17:28:12,308 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2014-08-22 17:28:12,315 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:12,328 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:12,330 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local558630407_0003_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:12,333 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/intermediate/part-00000:0+20
2014-08-22 17:28:12,334 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local558630407_0003_m_000000_0' done.
2014-08-22 17:28:12,334 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local558630407_0003_m_000000_0
2014-08-22 17:28:12,334 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:12,345 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2224ea85
2014-08-22 17:28:12,346 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,351 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:12,358 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 162 bytes
2014-08-22 17:28:12,358 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:12,360 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:12,375 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2014-08-22 17:28:12,376 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2014-08-22 17:28:12,392 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:28:12,392 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:28:12,404 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local558630407_0003_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:12,406 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,406 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local558630407_0003_r_000000_0 is allowed to commit now
2014-08-22 17:28:12,410 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local558630407_0003_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/cogroupsplit
2014-08-22 17:28:12,412 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:12,412 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local558630407_0003_r_000000_0' done.
2014-08-22 17:28:12,418 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/cogroupsplit/_temporary
2014-08-22 17:28:12,432 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,448 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,450 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/intermediate
2014-08-22 17:28:12,451 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/cogroupsplit
2014-08-22 17:28:12,463 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:12,464 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:12,490 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2014-08-22 17:28:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:12,491 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:12,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ipesplatform/none-unknown
2014-08-22 17:28:12,509 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1414702273_0004
2014-08-22 17:28:12,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:12,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:12,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1414702273_0004_m_000000_0
2014-08-22 17:28:12,558 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@444ef630
2014-08-22 17:28:12,559 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:12,560 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2f6a23cf
2014-08-22 17:28:12,561 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:12,563 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:12,700 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:12,700 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:12,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:12,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:12,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:12,716 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2014-08-22 17:28:12,719 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:12,722 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:12,725 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1414702273_0004_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:12,728 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:12,728 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1414702273_0004_m_000000_0' done.
2014-08-22 17:28:12,728 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1414702273_0004_m_000000_0
2014-08-22 17:28:12,728 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:12,733 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7291b9b0
2014-08-22 17:28:12,734 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,735 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:12,736 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 147 bytes
2014-08-22 17:28:12,736 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,737 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:12,737 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:12,748 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2014-08-22 17:28:12,748 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2014-08-22 17:28:12,758 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1414702273_0004_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:12,760 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:12,760 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1414702273_0004_r_000000_0 is allowed to commit now
2014-08-22 17:28:12,765 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1414702273_0004_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/none-unknown
2014-08-22 17:28:12,766 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:12,767 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1414702273_0004_r_000000_0' done.
2014-08-22 17:28:12,777 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/none-unknown/_temporary
2014-08-22 17:28:12,791 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,793 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/none-unknown
2014-08-22 17:28:12,806 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:12,807 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:12,833 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:12,833 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2014-08-22 17:28:12,834 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepre"]
2014-08-22 17:28:12,834 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:12,834 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:12,834 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:12,835 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...sionpipesplatform/oomepre
2014-08-22 17:28:12,852 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:12,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local2031276803_0005
2014-08-22 17:28:12,915 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:12,918 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:12,918 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2031276803_0005_m_000000_0
2014-08-22 17:28:12,920 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@15517e5e
2014-08-22 17:28:12,924 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt
2014-08-22 17:28:12,925 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5025bd56
2014-08-22 17:28:12,926 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:12,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:12,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:12,940 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2014-08-22 17:28:12,941 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepre"]
2014-08-22 17:28:12,943 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:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2014-08-22 17:28:12,946 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:12,947 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local2031276803_0005
java.lang.Exception: java.lang.OutOfMemoryError: fake error
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: 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:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2014-08-22 17:28:12,956 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] hadoop job job_local2031276803_0005 state at FAILED
2014-08-22 17:28:12,956 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] failure info: NA
2014-08-22 17:28:12,958 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events identify failed tasks
2014-08-22 17:28:12,958 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [test] task completion events count: 0
2014-08-22 17:28:12,958 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] stopping all jobs
2014-08-22 17:28:12,959 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] stopping: (1/1) ...sionpipesplatform/oomepre
2014-08-22 17:28:12,959 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] stopped all jobs
2014-08-22 17:28:12,959 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepre/_temporary
exception = cascading.flow.FlowException: local step failed
2014-08-22 17:28:12,960 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/oomepre
2014-08-22 17:28:12,972 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:12,973 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:12,988 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:12,989 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:12,989 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/copy"]
2014-08-22 17:28:12,989 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:12,990 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:12,990 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:12,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ressionpipesplatform/copy
2014-08-22 17:28:13,005 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,042 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local202788013_0006
2014-08-22 17:28:13,043 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:13,045 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:13,046 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local202788013_0006_m_000000_0
2014-08-22 17:28:13,048 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@251c135c
2014-08-22 17:28:13,049 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:13,050 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6cf84b0a
2014-08-22 17:28:13,052 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:13,057 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,058 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:13,064 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:13,065 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/copy"]
2014-08-22 17:28:13,066 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local202788013_0006_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:13,069 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:13,069 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local202788013_0006_m_000000_0 is allowed to commit now
2014-08-22 17:28:13,073 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local202788013_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/copy
2014-08-22 17:28:13,074 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:13,075 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local202788013_0006_m_000000_0' done.
2014-08-22 17:28:13,075 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local202788013_0006_m_000000_0
2014-08-22 17:28:13,075 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:13,085 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/copy/_temporary
2014-08-22 17:28:13,096 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,098 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/copy
2014-08-22 17:28:13,114 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:13,114 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:13,138 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:13,139 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:13,139 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2014-08-22 17:28:13,140 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:13,140 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:13,141 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:13,142 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...splatform/unknown-replace
2014-08-22 17:28:13,156 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,190 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1792056895_0007
2014-08-22 17:28:13,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:13,193 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:13,193 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1792056895_0007_m_000000_0
2014-08-22 17:28:13,195 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@51af7c57
2014-08-22 17:28:13,196 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:13,196 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3e93f13f
2014-08-22 17:28:13,198 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:13,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:13,212 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:13,212 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2014-08-22 17:28:13,214 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1792056895_0007_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:13,216 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:13,216 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1792056895_0007_m_000000_0 is allowed to commit now
2014-08-22 17:28:13,220 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1792056895_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown-replace
2014-08-22 17:28:13,221 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:13,221 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1792056895_0007_m_000000_0' done.
2014-08-22 17:28:13,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1792056895_0007_m_000000_0
2014-08-22 17:28:13,222 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:13,233 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown-replace/_temporary
2014-08-22 17:28:13,247 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,260 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,262 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/unknown-replace
2014-08-22 17:28:13,277 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:13,277 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:13,300 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:13,301 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:13,301 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2014-08-22 17:28:13,302 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:13,302 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:13,302 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:13,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...egression/complexlogicand
2014-08-22 17:28:13,318 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1046129256_0008
2014-08-22 17:28:13,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:13,355 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:13,355 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1046129256_0008_m_000000_0
2014-08-22 17:28:13,357 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5492de02
2014-08-22 17:28:13,358 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt
2014-08-22 17:28:13,359 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@225bcd91
2014-08-22 17:28:13,361 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:13,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:13,387 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:13,387 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2014-08-22 17:28:13,390 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1046129256_0008_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:13,392 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:13,392 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1046129256_0008_m_000000_0 is allowed to commit now
2014-08-22 17:28:13,395 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1046129256_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand
2014-08-22 17:28:13,397 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt:0+52
2014-08-22 17:28:13,397 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1046129256_0008_m_000000_0' done.
2014-08-22 17:28:13,398 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1046129256_0008_m_000000_0
2014-08-22 17:28:13,398 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:13,409 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand/_temporary
2014-08-22 17:28:13,422 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,424 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicand
2014-08-22 17:28:13,438 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:13,439 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:13,462 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:13,462 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:13,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2014-08-22 17:28:13,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:13,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:13,463 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:13,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...egression/complexlogicxor
2014-08-22 17:28:13,476 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1027472571_0009
2014-08-22 17:28:13,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:13,506 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:13,506 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1027472571_0009_m_000000_0
2014-08-22 17:28:13,508 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3dea382
2014-08-22 17:28:13,510 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt
2014-08-22 17:28:13,510 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@556b277f
2014-08-22 17:28:13,512 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:13,516 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,516 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:13,525 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt"]
2014-08-22 17:28:13,526 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2014-08-22 17:28:13,529 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1027472571_0009_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:13,531 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:13,531 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1027472571_0009_m_000000_0 is allowed to commit now
2014-08-22 17:28:13,534 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1027472571_0009_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor
2014-08-22 17:28:13,536 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lhs.txt:0+52
2014-08-22 17:28:13,536 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1027472571_0009_m_000000_0' done.
2014-08-22 17:28:13,536 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1027472571_0009_m_000000_0
2014-08-22 17:28:13,537 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:13,549 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor/_temporary
2014-08-22 17:28:13,561 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,563 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicxor
2014-08-22 17:28:13,575 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:13,576 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:13,607 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] starting
2014-08-22 17:28:13,608 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/upper.txt"]
2014-08-22 17:28:13,609 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:13,609 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2014-08-22 17:28:13,610 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] parallel execution is enabled: false
2014-08-22 17:28:13,610 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] starting jobs: 1
2014-08-22 17:28:13,610 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] allocating threads: 1
2014-08-22 17:28:13,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] starting step: (1/1) ...ionpipesplatform/oomepost
2014-08-22 17:28:13,625 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,627 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:13,660 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] submitted hadoop job: job_local1162578126_0010
2014-08-22 17:28:13,660 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] tracking url: http://localhost:8080/
2014-08-22 17:28:13,663 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:13,664 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1162578126_0010_m_000000_0
2014-08-22 17:28:13,666 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1212ee2a
2014-08-22 17:28:13,668 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/upper.txt
2014-08-22 17:28:13,669 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6ed3199e
2014-08-22 17:28:13,670 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:13,671 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:13,817 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:13,817 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:13,819 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,819 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:13,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/upper.txt"]
2014-08-22 17:28:13,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2014-08-22 17:28:13,833 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:13,836 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:13,838 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1162578126_0010_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:13,840 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/upper.txt:0+19
2014-08-22 17:28:13,841 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1162578126_0010_m_000000_0' done.
2014-08-22 17:28:13,841 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1162578126_0010_m_000000_0
2014-08-22 17:28:13,841 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1162578126_0010_m_000001_0
2014-08-22 17:28:13,843 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23930c3a
2014-08-22 17:28:13,844 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt
2014-08-22 17:28:13,845 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2c7103af
2014-08-22 17:28:13,846 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:13,846 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:13,986 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:13,987 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:13,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:13,992 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,009 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:14,009 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2014-08-22 17:28:14,011 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:14,014 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:14,016 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1162578126_0010_m_000001_0 is done. And is in the process of commiting
2014-08-22 17:28:14,019 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt:0+19
2014-08-22 17:28:14,019 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1162578126_0010_m_000001_0' done.
2014-08-22 17:28:14,019 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1162578126_0010_m_000001_0
2014-08-22 17:28:14,020 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:14,027 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@246d12a9
2014-08-22 17:28:14,028 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,029 INFO mapred.Merger (Merger.java:merge(408)) - Merging 2 sorted segments
2014-08-22 17:28:14,030 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 2 segments left of total size: 194 bytes
2014-08-22 17:28:14,030 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,031 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:14,031 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,041 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2014-08-22 17:28:14,041 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2014-08-22 17:28:14,046 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:28:14,046 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2014-08-22 17:28:14,047 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:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2014-08-22 17:28:14,049 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1162578126_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:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:522)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:421)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:398)
2014-08-22 17:28:14,056 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [lower*upper] hadoop job job_local1162578126_0010 state at FAILED
2014-08-22 17:28:14,056 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [lower*upper] failure info: NA
2014-08-22 17:28:14,057 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [lower*upper] task completion events identify failed tasks
2014-08-22 17:28:14,057 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [lower*upper] task completion events count: 0
2014-08-22 17:28:14,061 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] stopping all jobs
2014-08-22 17:28:14,062 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lower*upper] stopping: (1/1) ...ionpipesplatform/oomepost
2014-08-22 17:28:14,062 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] stopped all jobs
2014-08-22 17:28:14,062 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] shutting down job executor
2014-08-22 17:28:14,063 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lower*upper] shutdown complete
2014-08-22 17:28:14,063 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/oomepost/_temporary
exception = cascading.flow.FlowException: local step failed
2014-08-22 17:28:14,064 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/oomepost
2014-08-22 17:28:14,075 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:14,076 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:14,092 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:14,093 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2014-08-22 17:28:14,093 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2014-08-22 17:28:14,093 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:14,094 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:14,094 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:14,094 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...platform/lasteachmodified
2014-08-22 17:28:14,106 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,134 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local551058021_0011
2014-08-22 17:28:14,135 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:14,137 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:14,138 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local551058021_0011_m_000000_0
2014-08-22 17:28:14,140 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2ff44aa6
2014-08-22 17:28:14,142 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt
2014-08-22 17:28:14,142 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@70cfaf6e
2014-08-22 17:28:14,144 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:14,144 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:14,282 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:14,282 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:14,284 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:14,285 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt"]
2014-08-22 17:28:14,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2014-08-22 17:28:14,297 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:14,300 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:14,302 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local551058021_0011_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:14,305 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.10.txt:0+1449
2014-08-22 17:28:14,305 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local551058021_0011_m_000000_0' done.
2014-08-22 17:28:14,305 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local551058021_0011_m_000000_0
2014-08-22 17:28:14,305 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:14,309 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3cf522e8
2014-08-22 17:28:14,310 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,311 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:14,311 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 182 bytes
2014-08-22 17:28:14,312 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,312 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:14,313 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,321 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2014-08-22 17:28:14,321 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2014-08-22 17:28:14,328 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local551058021_0011_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:14,329 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,330 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local551058021_0011_r_000000_0 is allowed to commit now
2014-08-22 17:28:14,333 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local551058021_0011_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/lasteachmodified
2014-08-22 17:28:14,335 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:14,335 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local551058021_0011_r_000000_0' done.
2014-08-22 17:28:14,351 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/lasteachmodified/_temporary
2014-08-22 17:28:14,361 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,363 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/lasteachmodified
2014-08-22 17:28:14,375 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:14,375 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:14,394 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:14,394 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:14,395 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown"]
2014-08-22 17:28:14,395 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:14,395 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:14,395 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:14,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...sionpipesplatform/unknown
2014-08-22 17:28:14,410 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,446 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local93039965_0012
2014-08-22 17:28:14,447 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:14,450 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:14,450 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local93039965_0012_m_000000_0
2014-08-22 17:28:14,452 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@694b525c
2014-08-22 17:28:14,453 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:14,453 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@7c30cd64
2014-08-22 17:28:14,455 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:14,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:14,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:14,467 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown"]
2014-08-22 17:28:14,469 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local93039965_0012_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:14,470 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,471 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local93039965_0012_m_000000_0 is allowed to commit now
2014-08-22 17:28:14,474 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local93039965_0012_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown
2014-08-22 17:28:14,475 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:14,475 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local93039965_0012_m_000000_0' done.
2014-08-22 17:28:14,476 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local93039965_0012_m_000000_0
2014-08-22 17:28:14,476 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:14,491 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/unknown/_temporary
2014-08-22 17:28:14,501 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,504 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/unknown
2014-08-22 17:28:14,517 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:14,517 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:14,536 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:14,537 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/critics.txt"]
2014-08-22 17:28:14,537 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/varwidth"]
2014-08-22 17:28:14,538 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:14,539 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:14,539 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:14,540 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...ionpipesplatform/varwidth
2014-08-22 17:28:14,551 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,576 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local609572477_0013
2014-08-22 17:28:14,577 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:14,579 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:14,579 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local609572477_0013_m_000000_0
2014-08-22 17:28:14,581 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3cc62c07
2014-08-22 17:28:14,582 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/critics.txt
2014-08-22 17:28:14,582 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3c9ff588
2014-08-22 17:28:14,584 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:14,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:14,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:14,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/critics.txt"]
2014-08-22 17:28:14,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/varwidth"]
2014-08-22 17:28:14,598 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local609572477_0013_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:14,599 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:14,600 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local609572477_0013_m_000000_0 is allowed to commit now
2014-08-22 17:28:14,602 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local609572477_0013_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/varwidth
2014-08-22 17:28:14,604 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/critics.txt:0+828
2014-08-22 17:28:14,604 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local609572477_0013_m_000000_0' done.
2014-08-22 17:28:14,604 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local609572477_0013_m_000000_0
2014-08-22 17:28:14,604 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:14,610 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/varwidth/_temporary
2014-08-22 17:28:14,619 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:14,621 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/varwidth
2014-08-22 17:28:15,043 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:15,044 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:15,657 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] starting
2014-08-22 17:28:15,658 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.200.txt"]
2014-08-22 17:28:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2014-08-22 17:28:15,659 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] parallel execution is enabled: false
2014-08-22 17:28:15,660 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] starting jobs: 1
2014-08-22 17:28:15,661 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipeline] allocating threads: 1
2014-08-22 17:28:15,662 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipeline] starting step: (1/1) ...pipesplatform/deeppipline
2014-08-22 17:28:15,673 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:15,700 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipeline] submitted hadoop job: job_local560274089_0014
2014-08-22 17:28:15,700 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipeline] tracking url: http://localhost:8080/
2014-08-22 17:28:15,702 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:15,703 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local560274089_0014_m_000000_0
2014-08-22 17:28:15,704 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@67eb2e9f
2014-08-22 17:28:15,706 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.200.txt
2014-08-22 17:28:15,706 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4a4a117f
2014-08-22 17:28:15,707 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:15,707 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:16,082 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:16,083 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:16,084 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:16,085 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:16,324 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.200.txt"]
2014-08-22 17:28:16,325 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2014-08-22 17:28:16,612 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:16,630 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:16,632 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local560274089_0014_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:16,634 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache.200.txt:0+32599
2014-08-22 17:28:16,634 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local560274089_0014_m_000000_0' done.
2014-08-22 17:28:16,634 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local560274089_0014_m_000000_0
2014-08-22 17:28:16,634 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:16,638 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4ab24098
2014-08-22 17:28:16,639 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:16,639 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:16,640 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 35984 bytes
2014-08-22 17:28:16,640 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:16,641 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:16,641 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:16,783 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2014-08-22 17:28:16,783 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2014-08-22 17:28:17,281 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local560274089_0014_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,283 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,283 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local560274089_0014_r_000000_0 is allowed to commit now
2014-08-22 17:28:17,286 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local560274089_0014_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/deeppipline
2014-08-22 17:28:17,287 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:17,287 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local560274089_0014_r_000000_0' done.
2014-08-22 17:28:17,299 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/deeppipline/_temporary
2014-08-22 17:28:17,300 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/deeppipline
2014-08-22 17:28:17,310 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:17,311 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:17,320 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] starting
2014-08-22 17:28:17,320 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:17,320 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2014-08-22 17:28:17,320 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] parallel execution is enabled: false
2014-08-22 17:28:17,321 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] starting jobs: 1
2014-08-22 17:28:17,321 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [split] allocating threads: 1
2014-08-22 17:28:17,322 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] starting step: (1/1) ...latform/splitintermediate
2014-08-22 17:28:17,333 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:17,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] submitted hadoop job: job_local1209747190_0015
2014-08-22 17:28:17,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [split] tracking url: http://localhost:8080/
2014-08-22 17:28:17,361 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:17,361 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1209747190_0015_m_000000_0
2014-08-22 17:28:17,364 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@76f1a348
2014-08-22 17:28:17,366 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt
2014-08-22 17:28:17,367 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@d9ef365
2014-08-22 17:28:17,369 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:17,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:17,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:17,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt"]
2014-08-22 17:28:17,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2014-08-22 17:28:17,381 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1209747190_0015_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,383 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,383 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1209747190_0015_m_000000_0 is allowed to commit now
2014-08-22 17:28:17,386 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1209747190_0015_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate
2014-08-22 17:28:17,388 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower.txt:0+19
2014-08-22 17:28:17,388 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1209747190_0015_m_000000_0' done.
2014-08-22 17:28:17,389 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1209747190_0015_m_000000_0
2014-08-22 17:28:17,389 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:17,401 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate/_temporary
2014-08-22 17:28:17,410 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:17,411 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:17,425 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] starting
2014-08-22 17:28:17,425 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2014-08-22 17:28:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2014-08-22 17:28:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] parallel execution is enabled: false
2014-08-22 17:28:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] starting jobs: 1
2014-08-22 17:28:17,426 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [lhs+rhs] allocating threads: 1
2014-08-22 17:28:17,427 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs+rhs] starting step: (1/1) ...ipesplatform/groupbysplit
2014-08-22 17:28:17,439 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:17,475 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs+rhs] submitted hadoop job: job_local732747925_0016
2014-08-22 17:28:17,476 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [lhs+rhs] tracking url: http://localhost:8080/
2014-08-22 17:28:17,478 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:17,478 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local732747925_0016_m_000000_0
2014-08-22 17:28:17,480 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7a4f0b5b
2014-08-22 17:28:17,482 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate/part-00000
2014-08-22 17:28:17,482 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6b8612e4
2014-08-22 17:28:17,483 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:17,483 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:17,620 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:17,620 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:17,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:17,622 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:17,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2014-08-22 17:28:17,629 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2014-08-22 17:28:17,631 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:17,634 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:17,636 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local732747925_0016_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,638 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/splitintermediate/part-00000:0+20
2014-08-22 17:28:17,638 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local732747925_0016_m_000000_0' done.
2014-08-22 17:28:17,638 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local732747925_0016_m_000000_0
2014-08-22 17:28:17,639 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:17,642 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@55308275
2014-08-22 17:28:17,643 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,644 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:17,644 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 172 bytes
2014-08-22 17:28:17,645 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,645 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:17,646 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:17,650 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2014-08-22 17:28:17,651 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2014-08-22 17:28:17,656 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local732747925_0016_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,657 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,658 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local732747925_0016_r_000000_0 is allowed to commit now
2014-08-22 17:28:17,660 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local732747925_0016_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/groupbysplit
2014-08-22 17:28:17,662 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:17,662 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local732747925_0016_r_000000_0' done.
2014-08-22 17:28:17,670 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/groupbysplit/_temporary
2014-08-22 17:28:17,679 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:17,689 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:17,691 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/splitintermediate
2014-08-22 17:28:17,691 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/groupbysplit
2014-08-22 17:28:17,702 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:17,702 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:17,725 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] starting
2014-08-22 17:28:17,725 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:17,726 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2014-08-22 17:28:17,726 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] parallel execution is enabled: false
2014-08-22 17:28:17,726 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] starting jobs: 2
2014-08-22 17:28:17,726 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [**&%&%bar:bar@foo://bl...] allocating threads: 1
2014-08-22 17:28:17,727 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2014-08-22 17:28:17,737 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:17,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local704862622_0017
2014-08-22 17:28:17,764 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2014-08-22 17:28:17,766 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:17,766 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local704862622_0017_m_000000_0
2014-08-22 17:28:17,768 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4a62f5b
2014-08-22 17:28:17,770 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:17,770 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@42b996d7
2014-08-22 17:28:17,772 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:17,772 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:17,911 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:17,911 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:17,913 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:17,914 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:17,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:17,919 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2014-08-22 17:28:17,921 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:17,954 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:17,956 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local704862622_0017_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:17,958 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local704862622_0017_m_000000_0' done.
2014-08-22 17:28:17,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local704862622_0017_m_000000_0
2014-08-22 17:28:17,958 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:17,962 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@dc35b98
2014-08-22 17:28:17,962 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,963 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:17,963 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 77 bytes
2014-08-22 17:28:17,964 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,964 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:17,964 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:17,968 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2014-08-22 17:28:17,968 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][5751243494/__&%&%bar:bar@foo:_blah_/]
2014-08-22 17:28:17,981 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local704862622_0017_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:17,982 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:17,982 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local704862622_0017_r_000000_0 is allowed to commit now
2014-08-22 17:28:17,984 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local704862622_0017_r_000000_0' to file:/tmp/hadoop-teamcity/5751243494____bar_bar_foo__blah__DA1BA406940F4228B0840A44F1F11D9F
2014-08-22 17:28:17,986 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:17,986 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local704862622_0017_r_000000_0' done.
2014-08-22 17:28:17,998 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...ipesplatform/illegalchars
2014-08-22 17:28:18,008 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:18,032 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local401703460_0018
2014-08-22 17:28:18,032 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2014-08-22 17:28:18,034 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:18,034 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local401703460_0018_m_000000_0
2014-08-22 17:28:18,035 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@604fd0e9
2014-08-22 17:28:18,036 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/5751243494____bar_bar_foo__blah__DA1BA406940F4228B0840A44F1F11D9F/part-00000
2014-08-22 17:28:18,037 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@30d60f6e
2014-08-22 17:28:18,043 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 1
2014-08-22 17:28:18,043 INFO mapred.MapTask (MapTask.java:<init>(949)) - io.sort.mb = 100
2014-08-22 17:28:18,174 INFO mapred.MapTask (MapTask.java:<init>(961)) - data buffer = 79691776/99614720
2014-08-22 17:28:18,174 INFO mapred.MapTask (MapTask.java:<init>(962)) - record buffer = 262144/327680
2014-08-22 17:28:18,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:18,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:18,180 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][5751243494/__&%&%bar:bar@foo:_blah_/]
2014-08-22 17:28:18,181 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2014-08-22 17:28:18,182 INFO mapred.MapTask (MapTask.java:flush(1289)) - Starting flush of map output
2014-08-22 17:28:18,185 INFO mapred.MapTask (MapTask.java:sortAndSpill(1471)) - Finished spill 0
2014-08-22 17:28:18,186 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local401703460_0018_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:18,188 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/tmp/hadoop-teamcity/5751243494____bar_bar_foo__blah__DA1BA406940F4228B0840A44F1F11D9F/part-00000:0+170
2014-08-22 17:28:18,188 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local401703460_0018_m_000000_0' done.
2014-08-22 17:28:18,188 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local401703460_0018_m_000000_0
2014-08-22 17:28:18,188 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:18,192 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4351aa16
2014-08-22 17:28:18,192 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:18,193 INFO mapred.Merger (Merger.java:merge(408)) - Merging 1 sorted segments
2014-08-22 17:28:18,193 INFO mapred.Merger (Merger.java:merge(491)) - Down to the last merge-pass, with 1 segments left of total size: 77 bytes
2014-08-22 17:28:18,194 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:18,194 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.5.6
2014-08-22 17:28:18,194 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2014-08-22 17:28:18,198 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2014-08-22 17:28:18,199 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2014-08-22 17:28:18,203 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local401703460_0018_r_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:18,205 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:18,205 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local401703460_0018_r_000000_0 is allowed to commit now
2014-08-22 17:28:18,208 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local401703460_0018_r_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/illegalchars
2014-08-22 17:28:18,209 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - reduce > reduce
2014-08-22 17:28:18,209 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local401703460_0018_r_000000_0' done.
2014-08-22 17:28:18,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/illegalchars/_temporary
2014-08-22 17:28:18,229 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:18,231 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/illegalchars
2014-08-22 17:28:18,244 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:28:18,244 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:28:18,256 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting
2014-08-22 17:28:18,257 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:18,257 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2014-08-22 17:28:18,257 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] parallel execution is enabled: false
2014-08-22 17:28:18,257 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] starting jobs: 1
2014-08-22 17:28:18,257 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [test] allocating threads: 1
2014-08-22 17:28:18,258 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2014-08-22 17:28:18,267 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:18,295 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] submitted hadoop job: job_local1852409071_0019
2014-08-22 17:28:18,296 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [test] tracking url: http://localhost:8080/
2014-08-22 17:28:18,298 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:28:18,298 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1852409071_0019_m_000000_0
2014-08-22 17:28:18,299 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@32e02ddd
2014-08-22 17:28:18,301 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt
2014-08-22 17:28:18,301 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@5c4d0026
2014-08-22 17:28:18,302 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:28:18,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:28:18,305 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:28:18,309 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt"]
2014-08-22 17:28:18,309 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2014-08-22 17:28:18,311 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1852409071_0019_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:28:18,313 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:28:18,313 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1852409071_0019_m_000000_0 is allowed to commit now
2014-08-22 17:28:18,316 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1852409071_0019_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic
2014-08-22 17:28:18,317 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/lower+upper.txt:0+30
2014-08-22 17:28:18,317 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1852409071_0019_m_000000_0' done.
2014-08-22 17:28:18,318 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1852409071_0019_m_000000_0
2014-08-22 17:28:18,318 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:28:18,328 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic/_temporary
2014-08-22 17:28:18,338 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:28:18,340 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic