2015-08-13 17:56:08,673 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 17:56:08,721 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 17:56:08,721 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.RegressionPipesPlatformTest
2015-08-13 17:56:08,758 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 17:56:09,041 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 17:56:09,172 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:09,173 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:09,186 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: B583B3122BBF4CE58B1CFBB20B81EE13
2015-08-13 17:56:09,412 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 17:56:09,414 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:09,415 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:09,415 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2015-08-13 17:56:09,416 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:09,417 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:09,417 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:09,419 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...regression/complexlogicor
2015-08-13 17:56:09,467 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 17:56:09,721 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0001
2015-08-13 17:56:09,722 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:09,801 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt
2015-08-13 17:56:09,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:09,819 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:09,881 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:09,882 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor"]
2015-08-13 17:56:12,795 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicor/_temporary
2015-08-13 17:56:12,824 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicor
2015-08-13 17:56:12,853 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:12,854 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:12,877 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] starting
2015-08-13 17:56:12,878 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:56:12,879 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2015-08-13 17:56:12,880 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] parallel execution is enabled: false
2015-08-13 17:56:12,880 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] starting jobs: 1
2015-08-13 17:56:12,881 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] allocating threads: 1
2015-08-13 17:56:12,882 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] starting step: (1/1) ...ipesplatform/intermediate
2015-08-13 17:56:12,993 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] submitted hadoop job: job_local_0002
2015-08-13 17:56:12,994 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] tracking url: http://localhost:8080/
2015-08-13 17:56:13,000 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt
2015-08-13 17:56:13,007 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:13,007 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:13,022 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:56:13,022 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2015-08-13 17:56:16,012 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate/_temporary
2015-08-13 17:56:16,043 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:16,043 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:16,092 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-13 17:56:16,093 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2015-08-13 17:56:16,094 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2015-08-13 17:56:16,095 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: false
2015-08-13 17:56:16,096 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-08-13 17:56:16,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-08-13 17:56:16,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ipesplatform/cogroupsplit
2015-08-13 17:56:16,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_local_0003
2015-08-13 17:56:16,194 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://localhost:8080/
2015-08-13 17:56:16,200 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate/part-00000
2015-08-13 17:56:16,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:16,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:16,390 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/intermediate"]
2015-08-13 17:56:16,391 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-08-13 17:56:19,223 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:56:19,224 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:56:19,240 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-08-13 17:56:19,241 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/cogroupsplit"]
2015-08-13 17:56:19,258 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 17:56:19,258 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 17:56:22,217 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/cogroupsplit/_temporary
2015-08-13 17:56:22,276 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/intermediate
2015-08-13 17:56:22,276 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/cogroupsplit
2015-08-13 17:56:22,298 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:22,298 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:22,326 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:22,327 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:22,327 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2015-08-13 17:56:22,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:22,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:22,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:22,331 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/none-unknown
2015-08-13 17:56:22,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0004
2015-08-13 17:56:22,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:22,403 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:56:22,540 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:22,541 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:22,551 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:22,551 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2015-08-13 17:56:25,412 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:56:25,412 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:56:25,422 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2015-08-13 17:56:25,422 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/none-unknown"]
2015-08-13 17:56:28,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/none-unknown/_temporary
2015-08-13 17:56:28,438 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/none-unknown
2015-08-13 17:56:28,453 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:28,453 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:28,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:28,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2015-08-13 17:56:28,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepre"]
2015-08-13 17:56:28,483 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:28,483 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:28,483 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:28,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...sionpipesplatform/oomepre
2015-08-13 17:56:28,538 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0005
2015-08-13 17:56:28,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:28,545 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2015-08-13 17:56:28,552 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:28,553 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:28,561 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2015-08-13 17:56:28,562 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepre"]
2015-08-13 17:56:28,565 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-08-13 17:56:28,572 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0005
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:593)
at cascading.TestFunction.operate(TestFunction.java:74)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
2015-08-13 17:56:28,580 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] hadoop job job_local_0005 state at FAILED
2015-08-13 17:56:28,580 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] failure info: NA
2015-08-13 17:56:28,581 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events identify failed tasks
2015-08-13 17:56:28,582 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [test] task completion events count: 0
2015-08-13 17:56:28,582 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopping all jobs
2015-08-13 17:56:28,583 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] stopping: (1/1) ...sionpipesplatform/oomepre
2015-08-13 17:56:28,583 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] stopped all jobs
2015-08-13 17:56:28,584 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepre/_temporary
exception = cascading.flow.FlowException: local step failed
2015-08-13 17:56:28,585 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/oomepre
2015-08-13 17:56:28,598 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:28,598 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:28,614 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:28,614 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:28,615 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/copy"]
2015-08-13 17:56:28,616 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:28,616 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:28,617 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:28,618 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ressionpipesplatform/copy
2015-08-13 17:56:28,668 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0006
2015-08-13 17:56:28,668 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:28,674 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:56:28,680 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:28,681 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:28,686 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:28,687 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/copy"]
2015-08-13 17:56:31,685 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/copy/_temporary
2015-08-13 17:56:31,709 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/copy
2015-08-13 17:56:31,728 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:31,729 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:31,752 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:31,753 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:31,754 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2015-08-13 17:56:31,755 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:31,755 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:31,756 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:31,757 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...splatform/unknown-replace
2015-08-13 17:56:31,802 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0007
2015-08-13 17:56:31,802 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:31,808 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:56:31,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:31,813 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:31,822 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:31,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown-replace"]
2015-08-13 17:56:34,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown-replace/_temporary
2015-08-13 17:56:34,841 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/unknown-replace
2015-08-13 17:56:34,858 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:34,859 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:34,881 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:34,882 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2015-08-13 17:56:34,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:34,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:34,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:34,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...egression/complexlogicand
2015-08-13 17:56:34,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0008
2015-08-13 17:56:34,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:34,933 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt
2015-08-13 17:56:34,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:34,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:34,948 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:34,948 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand"]
2015-08-13 17:56:37,944 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicand/_temporary
2015-08-13 17:56:37,957 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicand
2015-08-13 17:56:37,973 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:37,974 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:37,996 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:37,997 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:37,998 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2015-08-13 17:56:37,998 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:37,999 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:37,999 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:38,001 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...egression/complexlogicxor
2015-08-13 17:56:38,041 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0009
2015-08-13 17:56:38,041 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:38,047 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt
2015-08-13 17:56:38,052 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:38,052 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:38,061 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2015-08-13 17:56:38,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor"]
2015-08-13 17:56:41,056 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/regression/complexlogicxor/_temporary
2015-08-13 17:56:41,069 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/regression/complexlogicxor
2015-08-13 17:56:41,084 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:41,084 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:41,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-13 17:56:41,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2015-08-13 17:56:41,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:56:41,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2015-08-13 17:56:41,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: false
2015-08-13 17:56:41,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-13 17:56:41,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-13 17:56:41,132 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ionpipesplatform/oomepost
2015-08-13 17:56:41,184 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local_0010
2015-08-13 17:56:41,184 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-13 17:56:41,189 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt
2015-08-13 17:56:41,331 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:41,331 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:41,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2015-08-13 17:56:41,342 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-13 17:56:44,192 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt
2015-08-13 17:56:44,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:44,327 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:44,338 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:56:44,339 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-13 17:56:47,202 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:56:47,203 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:56:47,213 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-13 17:56:47,214 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepost"]
2015-08-13 17:56:47,219 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 17:56:47,220 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-13 17:56:47,221 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - 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:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 17:56:47,228 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
java.lang.OutOfMemoryError: fake error
at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:643)
at cascading.TestFunction.operate(TestFunction.java:74)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:45)
at cascading.flow.stream.OpenDuct.receive(OpenDuct.java:28)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:93)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:136)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:519)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:260)
2015-08-13 17:56:47,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] hadoop job job_local_0010 state at FAILED
2015-08-13 17:56:47,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] failure info: NA
2015-08-13 17:56:47,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events identify failed tasks
2015-08-13 17:56:47,235 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [lower*upper] task completion events count: 0
2015-08-13 17:56:47,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopping all jobs
2015-08-13 17:56:47,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] stopping: (1/1) ...ionpipesplatform/oomepost
2015-08-13 17:56:47,236 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] stopped all jobs
2015-08-13 17:56:47,237 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/oomepost/_temporary
exception = cascading.flow.FlowException: local step failed
2015-08-13 17:56:47,238 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/oomepost
2015-08-13 17:56:47,250 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:47,251 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:47,268 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:47,269 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2015-08-13 17:56:47,270 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2015-08-13 17:56:47,271 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:47,271 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:47,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:47,273 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...platform/lasteachmodified
2015-08-13 17:56:47,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0011
2015-08-13 17:56:47,311 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:47,315 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2015-08-13 17:56:47,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:47,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:47,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2015-08-13 17:56:47,475 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2015-08-13 17:56:50,321 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:56:50,321 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:56:50,328 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2015-08-13 17:56:50,328 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/lasteachmodified"]
2015-08-13 17:56:53,333 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/lasteachmodified/_temporary
2015-08-13 17:56:53,345 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/lasteachmodified
2015-08-13 17:56:53,360 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:53,360 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:53,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:53,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:53,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown"]
2015-08-13 17:56:53,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:53,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:53,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:53,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...sionpipesplatform/unknown
2015-08-13 17:56:53,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0012
2015-08-13 17:56:53,424 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:53,428 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:56:53,433 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:53,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:53,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:56:53,443 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown"]
2015-08-13 17:56:56,436 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/unknown/_temporary
2015-08-13 17:56:56,447 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/unknown
2015-08-13 17:56:56,462 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:56:56,462 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:56:56,481 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:56:56,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/critics.txt"]
2015-08-13 17:56:56,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/varwidth"]
2015-08-13 17:56:56,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:56:56,482 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:56:56,483 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:56:56,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ionpipesplatform/varwidth
2015-08-13 17:56:56,518 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0013
2015-08-13 17:56:56,519 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:56:56,523 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/critics.txt
2015-08-13 17:56:56,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:56:56,528 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:56:56,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/critics.txt"]
2015-08-13 17:56:56,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/varwidth"]
2015-08-13 17:56:59,536 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/varwidth/_temporary
2015-08-13 17:56:59,547 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/varwidth
2015-08-13 17:57:00,090 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:57:00,091 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:57:00,779 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] starting
2015-08-13 17:57:00,780 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2015-08-13 17:57:00,780 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2015-08-13 17:57:00,780 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] parallel execution is enabled: false
2015-08-13 17:57:00,780 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] starting jobs: 1
2015-08-13 17:57:00,780 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipeline] allocating threads: 1
2015-08-13 17:57:00,783 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipeline] starting step: (1/1) ...pipesplatform/deeppipline
2015-08-13 17:57:00,829 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipeline] submitted hadoop job: job_local_0014
2015-08-13 17:57:00,829 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipeline] tracking url: http://localhost:8080/
2015-08-13 17:57:00,835 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.200.txt
2015-08-13 17:57:01,209 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:01,211 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:01,490 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2015-08-13 17:57:01,490 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2015-08-13 17:57:03,842 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:57:03,842 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:57:03,973 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2015-08-13 17:57:03,973 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/deeppipline"]
2015-08-13 17:57:06,850 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/deeppipline/_temporary
2015-08-13 17:57:06,851 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/deeppipline
2015-08-13 17:57:06,862 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:57:06,862 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:57:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] starting
2015-08-13 17:57:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:57:06,872 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2015-08-13 17:57:06,873 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] parallel execution is enabled: false
2015-08-13 17:57:06,873 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] starting jobs: 1
2015-08-13 17:57:06,873 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [split] allocating threads: 1
2015-08-13 17:57:06,874 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] starting step: (1/1) ...latform/splitintermediate
2015-08-13 17:57:06,910 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] submitted hadoop job: job_local_0015
2015-08-13 17:57:06,911 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [split] tracking url: http://localhost:8080/
2015-08-13 17:57:06,916 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt
2015-08-13 17:57:06,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:06,921 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:06,926 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2015-08-13 17:57:06,926 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2015-08-13 17:57:09,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate/_temporary
2015-08-13 17:57:09,930 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:57:09,930 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:57:09,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] starting
2015-08-13 17:57:09,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2015-08-13 17:57:09,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2015-08-13 17:57:09,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] parallel execution is enabled: false
2015-08-13 17:57:09,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] starting jobs: 1
2015-08-13 17:57:09,947 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs+rhs] allocating threads: 1
2015-08-13 17:57:09,947 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] starting step: (1/1) ...ipesplatform/groupbysplit
2015-08-13 17:57:09,983 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] submitted hadoop job: job_local_0016
2015-08-13 17:57:09,984 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs+rhs] tracking url: http://localhost:8080/
2015-08-13 17:57:09,988 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate/part-00000
2015-08-13 17:57:10,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:10,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:10,134 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/splitintermediate"]
2015-08-13 17:57:10,135 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-08-13 17:57:12,996 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:57:12,997 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:57:13,002 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-08-13 17:57:13,002 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/groupbysplit"]
2015-08-13 17:57:16,003 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/groupbysplit/_temporary
2015-08-13 17:57:16,026 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/groupbysplit
2015-08-13 17:57:16,026 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/splitintermediate
2015-08-13 17:57:16,040 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:57:16,041 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:57:16,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] starting
2015-08-13 17:57:16,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:57:16,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2015-08-13 17:57:16,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] parallel execution is enabled: false
2015-08-13 17:57:16,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] starting jobs: 2
2015-08-13 17:57:16,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [**&%&%bar:bar@foo://bl...] allocating threads: 1
2015-08-13 17:57:16,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2015-08-13 17:57:16,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0017
2015-08-13 17:57:16,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-08-13 17:57:16,116 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:57:16,261 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:16,262 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:16,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:57:16,267 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-13 17:57:19,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:57:19,121 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:57:19,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-13 17:57:19,126 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][4201831465/__&%&%bar:bar@foo:_blah_/]
2015-08-13 17:57:22,128 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...ipesplatform/illegalchars
2015-08-13 17:57:22,159 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0018
2015-08-13 17:57:22,160 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-08-13 17:57:22,164 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/4201831465____bar_bar_foo__blah__DCAA0016B291434D9D572F84053D4D41/part-00000
2015-08-13 17:57:22,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:22,302 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:22,307 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][4201831465/__&%&%bar:bar@foo:_blah_/]
2015-08-13 17:57:22,307 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-13 17:57:25,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-13 17:57:25,169 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-13 17:57:25,173 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-13 17:57:25,174 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/illegalchars"]
2015-08-13 17:57:28,180 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/illegalchars/_temporary
2015-08-13 17:57:28,190 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/illegalchars
2015-08-13 17:57:28,201 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 17:57:28,201 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 17:57:28,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-13 17:57:28,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:57:28,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2015-08-13 17:57:28,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-13 17:57:28,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-13 17:57:28,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-13 17:57:28,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2015-08-13 17:57:28,245 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local_0019
2015-08-13 17:57:28,246 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-13 17:57:28,249 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2015-08-13 17:57:28,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 17:57:28,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 17:57:28,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2015-08-13 17:57:28,257 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic"]
2015-08-13 17:57:31,252 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic/_temporary
2015-08-13 17:57:31,262 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/ungrouped-unknown-nondeterministic