Class cascading.RegressionPipesPlatformTest

18

tests

0

failures

0

ignored

1m25.48s

duration

100%

successful

Tests

Test Duration Result
testCoGroupSplitPipe 9.575s passed
testComplexLogicAnd 3.129s passed
testComplexLogicOr 4.107s passed
testComplexLogicXor 3.159s passed
testCopy 3.121s passed
testDeepPipeline 9.801s passed
testDupeHeadNames 0.013s passed
testDupeTailNames 0.013s passed
testGroupBySplitPipe 9.203s passed
testGroupNoneSortUnknown 6.194s passed
testIllegalCharsInTempFiles 12.164s passed
testLastEachNotModified 6.136s passed
testOOMEPostGroup 6.203s passed
testOOMEPreGroup 0.189s passed
testUnGroupUnknown 3.077s passed
testUnknown 3.144s passed
testUnknownReplace 3.130s passed
testVarWidth 3.123s passed

Standard output

2016-05-17 21:46:12,029 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 21:46:12,046 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.RegressionPipesPlatformTest, with platform: hadoop
2016-05-17 21:46:12,072 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 21:46:12,288 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-17 21:46:12,392 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:12,393 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:12,488 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: A5796332F8AF422698C734EFD91386FF
2016-05-17 21:46:12,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.096
2016-05-17 21:46:12,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:12,627 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:12,811 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 21:46:12,813 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:12,813 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:12,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2016-05-17 21:46:12,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:12,814 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:12,816 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:12,817 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...regression/complexlogicor
2016-05-17 21:46:12,848 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 21:46:13,105 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0001
2016-05-17 21:46:13,106 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:13,168 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt
2016-05-17 21:46:13,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:13,185 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:13,200 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C44A4703C39F457695095E0168FF5AD8, ordinal: 0
2016-05-17 21:46:13,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:13,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2016-05-17 21:46:13,234 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44A4703C39F457695095E0168FF5AD8, mem on start (mb), free: 188, total: 223, max: 672
2016-05-17 21:46:13,246 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44A4703C39F457695095E0168FF5AD8, mem on close (mb), free: 188, total: 223, max: 672
2016-05-17 21:46:16,153 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor/_temporary
2016-05-17 21:46:16,155 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.338
2016-05-17 21:46:16,176 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor
2016-05-17 21:46:16,198 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:16,199 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:16,266 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2016-05-17 21:46:16,269 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:16,269 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:16,285 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] starting
2016-05-17 21:46:16,286 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:46:16,286 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2016-05-17 21:46:16,287 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  parallel execution of steps is enabled: false
2016-05-17 21:46:16,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  executing total steps: 1
2016-05-17 21:46:16,288 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  allocating management threads: 1
2016-05-17 21:46:16,291 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] starting step: (1/1) ...oupSplitPipe/intermediate
2016-05-17 21:46:16,392 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] submitted hadoop job: job_local_0002
2016-05-17 21:46:16,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] tracking url: http://localhost:8080/
2016-05-17 21:46:16,400 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:46:16,408 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:16,409 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:16,427 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E7705AB3A8484F48A738B6F75E294080, ordinal: 0
2016-05-17 21:46:16,431 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:46:16,431 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2016-05-17 21:46:16,432 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7705AB3A8484F48A738B6F75E294080, mem on start (mb), free: 178, total: 223, max: 672
2016-05-17 21:46:16,434 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E7705AB3A8484F48A738B6F75E294080, mem on close (mb), free: 178, total: 223, max: 672
2016-05-17 21:46:19,412 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate/_temporary
2016-05-17 21:46:19,413 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  completed in: 00:03.127
2016-05-17 21:46:19,435 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:19,436 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:19,528 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-05-17 21:46:19,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:19,533 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:19,576 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-17 21:46:19,577 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2016-05-17 21:46:19,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2016-05-17 21:46:19,579 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  parallel execution of steps is enabled: false
2016-05-17 21:46:19,580 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  executing total steps: 1
2016-05-17 21:46:19,580 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  allocating management threads: 1
2016-05-17 21:46:19,581 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...oupSplitPipe/cogroupsplit
2016-05-17 21:46:19,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted hadoop job: job_local_0003
2016-05-17 21:46:19,663 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tracking url: http://localhost:8080/
2016-05-17 21:46:19,668 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate/part-00000
2016-05-17 21:46:19,798 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:19,798 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:19,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EDDF342716E240CFB7E00379ADD59D6C, ordinal: 0
2016-05-17 21:46:19,819 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2016-05-17 21:46:19,819 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2016-05-17 21:46:19,819 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDDF342716E240CFB7E00379ADD59D6C, mem on start (mb), free: 65, total: 223, max: 672
2016-05-17 21:46:19,827 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDDF342716E240CFB7E00379ADD59D6C, mem on close (mb), free: 65, total: 223, max: 672
2016-05-17 21:46:22,683 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:46:22,683 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:46:22,699 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E5917D35566F42B898B746791854AF4B, ordinal: 1
2016-05-17 21:46:22,702 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2016-05-17 21:46:22,702 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2016-05-17 21:46:22,703 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5917D35566F42B898B746791854AF4B, mem on start (mb), free: 63, total: 223, max: 672
2016-05-17 21:46:22,718 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:46:22,718 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:46:22,727 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E5917D35566F42B898B746791854AF4B, mem on close (mb), free: 62, total: 223, max: 672
2016-05-17 21:46:25,682 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit/_temporary
2016-05-17 21:46:25,682 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs]  completed in: 00:06.105
2016-05-17 21:46:25,752 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit
2016-05-17 21:46:25,752 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testCoGroupSplitPipe/intermediate
2016-05-17 21:46:25,768 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:25,768 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:25,820 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-05-17 21:46:25,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:25,822 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:25,854 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:25,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:25,855 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2016-05-17 21:46:25,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:25,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:25,857 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:25,858 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...eSortUnknown/none-unknown
2016-05-17 21:46:25,916 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0004
2016-05-17 21:46:25,917 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:25,921 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:46:26,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:26,019 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:26,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E73A63620E2144F1BEE3FD03FC6131A6, ordinal: 0
2016-05-17 21:46:26,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:26,028 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2016-05-17 21:46:26,029 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E73A63620E2144F1BEE3FD03FC6131A6, mem on start (mb), free: 105, total: 318, max: 672
2016-05-17 21:46:26,031 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E73A63620E2144F1BEE3FD03FC6131A6, mem on close (mb), free: 105, total: 318, max: 672
2016-05-17 21:46:28,929 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:46:28,931 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:46:28,942 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E71C98DEA08E4DAE85377C3AF5274336, ordinal: 1
2016-05-17 21:46:28,943 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2016-05-17 21:46:28,943 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2016-05-17 21:46:28,943 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E71C98DEA08E4DAE85377C3AF5274336, mem on start (mb), free: 104, total: 318, max: 672
2016-05-17 21:46:28,957 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E71C98DEA08E4DAE85377C3AF5274336, mem on close (mb), free: 104, total: 318, max: 672
2016-05-17 21:46:31,934 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown/_temporary
2016-05-17 21:46:31,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:06.080
2016-05-17 21:46:31,946 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown
2016-05-17 21:46:31,957 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:31,958 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:31,997 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-17 21:46:31,998 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:31,999 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:32,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:32,043 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:46:32,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2016-05-17 21:46:32,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:32,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:32,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:32,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) .../testOOMEPreGroup/oomepre
2016-05-17 21:46:32,086 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0005
2016-05-17 21:46:32,088 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:32,096 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:46:32,101 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:32,101 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:32,110 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D02DDF0D7C554F42AC2D077D49FFDB0C, ordinal: 0
2016-05-17 21:46:32,111 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:46:32,112 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2016-05-17 21:46:32,112 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D02DDF0D7C554F42AC2D077D49FFDB0C, mem on start (mb), free: 94, total: 318, max: 672
2016-05-17 21:46:32,115 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught OutOfMemoryException, will not trap, rethrowing
java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:583)
	at cascading.TestFunction.operate(TestFunction.java:75)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	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)
2016-05-17 21:46:32,120 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D02DDF0D7C554F42AC2D077D49FFDB0C, mem on close (mb), free: 94, total: 318, max: 672
2016-05-17 21:46:32,121 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0005
java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:583)
	at cascading.TestFunction.operate(TestFunction.java:75)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	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)
2016-05-17 21:46:32,130 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [test] hadoop job job_local_0005 state at FAILED
2016-05-17 21:46:32,130 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [test] failure info: NA
2016-05-17 21:46:32,131 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [test] task completion events identify failed tasks
2016-05-17 21:46:32,131 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [test] task completion events count: 0
2016-05-17 21:46:32,132 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping all jobs
2016-05-17 21:46:32,133 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopping: (1/1) .../testOOMEPreGroup/oomepre
2016-05-17 21:46:32,133 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] stopped all jobs
2016-05-17 21:46:32,134 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPreGroup/oomepre/_temporary
2016-05-17 21:46:32,134 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.090
exception = cascading.flow.FlowException: local step failed: (1/1) .../testOOMEPreGroup/oomepre
2016-05-17 21:46:32,136 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testOOMEPreGroup/oomepre
2016-05-17 21:46:32,149 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:32,149 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:32,181 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-17 21:46:32,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:32,182 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:32,191 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:32,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:32,192 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCopy/copy"]
2016-05-17 21:46:32,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:32,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:32,193 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:32,194 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-05-17 21:46:32,231 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0006
2016-05-17 21:46:32,232 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:32,236 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:46:32,240 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:32,241 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:32,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE4BA1BC33BC4550A5323CFB7F8049AA, ordinal: 0
2016-05-17 21:46:32,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:32,249 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCopy/copy"]
2016-05-17 21:46:32,249 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4BA1BC33BC4550A5323CFB7F8049AA, mem on start (mb), free: 86, total: 318, max: 672
2016-05-17 21:46:32,250 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE4BA1BC33BC4550A5323CFB7F8049AA, mem on close (mb), free: 86, total: 318, max: 672
2016-05-17 21:46:35,247 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testCopy/copy/_temporary
2016-05-17 21:46:35,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.056
2016-05-17 21:46:35,257 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testCopy/copy
2016-05-17 21:46:35,271 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:35,271 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:35,308 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 21:46:35,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:35,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:35,325 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:35,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:35,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2016-05-17 21:46:35,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:35,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:35,326 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:35,327 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...wnReplace/unknown-replace
2016-05-17 21:46:35,361 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0007
2016-05-17 21:46:35,362 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:35,366 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:46:35,370 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:35,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:35,379 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C528E3626F0149419A91D007F6F06CB0, ordinal: 0
2016-05-17 21:46:35,380 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:35,381 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2016-05-17 21:46:35,381 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C528E3626F0149419A91D007F6F06CB0, mem on start (mb), free: 77, total: 318, max: 672
2016-05-17 21:46:35,383 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C528E3626F0149419A91D007F6F06CB0, mem on close (mb), free: 77, total: 318, max: 672
2016-05-17 21:46:38,370 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknownReplace/unknown-replace/_temporary
2016-05-17 21:46:38,370 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.044
2016-05-17 21:46:38,386 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testUnknownReplace/unknown-replace
2016-05-17 21:46:38,400 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:38,401 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:38,442 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-05-17 21:46:38,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:38,444 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:38,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:38,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:38,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2016-05-17 21:46:38,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:38,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:38,459 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:38,460 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...egression/complexlogicand
2016-05-17 21:46:38,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0008
2016-05-17 21:46:38,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:38,496 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt
2016-05-17 21:46:38,500 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:38,500 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:38,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3765B3DD3F144C88FD0D570419CE46A, ordinal: 0
2016-05-17 21:46:38,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:38,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2016-05-17 21:46:38,509 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3765B3DD3F144C88FD0D570419CE46A, mem on start (mb), free: 66, total: 318, max: 672
2016-05-17 21:46:38,511 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3765B3DD3F144C88FD0D570419CE46A, mem on close (mb), free: 66, total: 318, max: 672
2016-05-17 21:46:41,507 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand/_temporary
2016-05-17 21:46:41,507 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.048
2016-05-17 21:46:41,516 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand
2016-05-17 21:46:41,530 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:41,531 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:41,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-17 21:46:41,587 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:41,588 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:41,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:41,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:41,608 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2016-05-17 21:46:41,608 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:41,609 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:41,609 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:41,610 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...egression/complexlogicxor
2016-05-17 21:46:41,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0009
2016-05-17 21:46:41,648 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:41,654 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt
2016-05-17 21:46:41,659 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:41,659 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:41,669 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A82AB53FB9D545FDA901F2602F1B69BE, ordinal: 0
2016-05-17 21:46:41,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lhs.txt"]
2016-05-17 21:46:41,670 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2016-05-17 21:46:41,671 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A82AB53FB9D545FDA901F2602F1B69BE, mem on start (mb), free: 116, total: 318, max: 672
2016-05-17 21:46:41,673 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A82AB53FB9D545FDA901F2602F1B69BE, mem on close (mb), free: 116, total: 318, max: 672
2016-05-17 21:46:44,664 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor/_temporary
2016-05-17 21:46:44,665 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.057
2016-05-17 21:46:44,675 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor
2016-05-17 21:46:44,690 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:44,691 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:44,744 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-17 21:46:44,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:44,745 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:44,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-17 21:46:44,777 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:46:44,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:46:44,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2016-05-17 21:46:44,778 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: false
2016-05-17 21:46:44,779 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-17 21:46:44,782 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-17 21:46:44,783 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...estOOMEPostGroup/oomepost
2016-05-17 21:46:44,838 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local_0010
2016-05-17 21:46:44,842 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-17 21:46:44,845 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt
2016-05-17 21:46:44,940 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:44,940 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:44,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, ordinal: 0
2016-05-17 21:46:44,950 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/upper.txt"]
2016-05-17 21:46:44,950 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 21:46:44,950 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, mem on start (mb), free: 100, total: 414, max: 672
2016-05-17 21:46:44,953 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, mem on close (mb), free: 100, total: 414, max: 672
2016-05-17 21:46:47,846 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:46:47,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:47,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:47,949 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, ordinal: 0
2016-05-17 21:46:47,950 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:46:47,950 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 21:46:47,950 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, mem on start (mb), free: 94, total: 509, max: 672
2016-05-17 21:46:47,952 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE427E291E8A42AB94942074A2CECFC9, mem on close (mb), free: 94, total: 509, max: 672
2016-05-17 21:46:50,854 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:46:50,854 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:46:50,862 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E3D0D7645FA242749CD2E79BDF73ABD8, ordinal: 1
2016-05-17 21:46:50,863 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 21:46:50,864 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2016-05-17 21:46:50,864 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3D0D7645FA242749CD2E79BDF73ABD8, mem on start (mb), free: 93, total: 509, max: 672
2016-05-17 21:46:50,868 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:46:50,868 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 21:46:50,869 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught OutOfMemoryException, will not trap, rethrowing
java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:635)
	at cascading.TestFunction.operate(TestFunction.java:75)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.duct.OpenDuct.receive(OpenDuct.java:45)
	at cascading.flow.stream.duct.OpenDuct.receive(OpenDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:147)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
	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)
2016-05-17 21:46:50,872 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0010
java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:635)
	at cascading.TestFunction.operate(TestFunction.java:75)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.duct.OpenDuct.receive(OpenDuct.java:45)
	at cascading.flow.stream.duct.OpenDuct.receive(OpenDuct.java:28)
	at cascading.flow.hadoop.stream.HadoopGroupGate.accept(HadoopGroupGate.java:147)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
	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)
2016-05-17 21:46:50,875 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] hadoop job job_local_0010 state at FAILED
2016-05-17 21:46:50,875 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] failure info: NA
2016-05-17 21:46:50,876 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events identify failed tasks
2016-05-17 21:46:50,876 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] task completion events count: 0
2016-05-17 21:46:50,876 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-17 21:46:50,877 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...estOOMEPostGroup/oomepost
2016-05-17 21:46:50,877 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-17 21:46:50,877 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testOOMEPostGroup/oomepost/_temporary
2016-05-17 21:46:50,878 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:06.100
exception = cascading.flow.FlowException: local step failed: (1/1) ...estOOMEPostGroup/oomepost
2016-05-17 21:46:50,879 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testOOMEPostGroup/oomepost
2016-05-17 21:46:50,888 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:50,888 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:50,928 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 21:46:50,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:46:50,929 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:50,945 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:50,946 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:46:50,947 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2016-05-17 21:46:50,948 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:50,948 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:50,949 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:50,950 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...Modified/lasteachmodified
2016-05-17 21:46:50,987 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0011
2016-05-17 21:46:50,988 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:50,994 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt
2016-05-17 21:46:51,090 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:51,090 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:51,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEC6D91846E74254B48465B6D97BE83F, ordinal: 0
2016-05-17 21:46:51,099 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.10.txt"]
2016-05-17 21:46:51,099 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2016-05-17 21:46:51,099 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEC6D91846E74254B48465B6D97BE83F, mem on start (mb), free: 46, total: 572, max: 672
2016-05-17 21:46:51,103 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEC6D91846E74254B48465B6D97BE83F, mem on close (mb), free: 46, total: 572, max: 672
2016-05-17 21:46:53,998 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:46:53,998 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:46:54,005 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C711951D742C40038C2930E8A015CA6F, ordinal: 1
2016-05-17 21:46:54,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2016-05-17 21:46:54,006 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2016-05-17 21:46:54,006 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C711951D742C40038C2930E8A015CA6F, mem on start (mb), free: 45, total: 572, max: 672
2016-05-17 21:46:54,012 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C711951D742C40038C2930E8A015CA6F, mem on close (mb), free: 45, total: 572, max: 672
2016-05-17 21:46:57,005 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testLastEachNotModified/lasteachmodified/_temporary
2016-05-17 21:46:57,007 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:06.060
2016-05-17 21:46:57,015 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testLastEachNotModified/lasteachmodified
2016-05-17 21:46:57,025 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:46:57,025 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:46:57,071 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 21:46:57,073 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:46:57,073 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:46:57,088 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:46:57,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:57,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknown/unknown"]
2016-05-17 21:46:57,089 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:46:57,090 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:46:57,090 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:46:57,091 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...tform/testUnknown/unknown
2016-05-17 21:46:57,130 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0012
2016-05-17 21:46:57,130 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:46:57,138 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:46:57,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:46:57,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:46:57,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DFED25536A4044D18B0ABE873FBB0712, ordinal: 0
2016-05-17 21:46:57,154 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:46:57,155 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknown/unknown"]
2016-05-17 21:46:57,155 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFED25536A4044D18B0ABE873FBB0712, mem on start (mb), free: 35, total: 572, max: 672
2016-05-17 21:46:57,159 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DFED25536A4044D18B0ABE873FBB0712, mem on close (mb), free: 35, total: 572, max: 672
2016-05-17 21:47:00,150 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnknown/unknown/_temporary
2016-05-17 21:47:00,150 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.061
2016-05-17 21:47:00,159 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testUnknown/unknown
2016-05-17 21:47:00,184 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:00,185 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:00,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-05-17 21:47:00,221 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:47:00,222 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:00,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:47:00,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/critics.txt"]
2016-05-17 21:47:00,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testVarWidth/varwidth"]
2016-05-17 21:47:00,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:47:00,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:47:00,236 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:47:00,237 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...orm/testVarWidth/varwidth
2016-05-17 21:47:00,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0013
2016-05-17 21:47:00,265 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:47:00,271 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/critics.txt
2016-05-17 21:47:00,274 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:00,275 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:00,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCBCC80CAA9B4B73B24B6514904AE376, ordinal: 0
2016-05-17 21:47:00,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/critics.txt"]
2016-05-17 21:47:00,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testVarWidth/varwidth"]
2016-05-17 21:47:00,284 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCBCC80CAA9B4B73B24B6514904AE376, mem on start (mb), free: 83, total: 572, max: 672
2016-05-17 21:47:00,287 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCBCC80CAA9B4B73B24B6514904AE376, mem on close (mb), free: 83, total: 572, max: 672
2016-05-17 21:47:03,273 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testVarWidth/varwidth/_temporary
2016-05-17 21:47:03,274 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.040
2016-05-17 21:47:03,282 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testVarWidth/varwidth
2016-05-17 21:47:03,290 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:03,291 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:03,293 WARN  planner.FlowPlanner (FlowPlanner.java:verifyPipeAssemblyEndPoints(464)) - duplicate head name found, not an error but heads should have unique names: 'test'
2016-05-17 21:47:03,295 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testDupeHeadNames/unknown
2016-05-17 21:47:03,306 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:03,306 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:03,309 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testDupeTailNames/unknown
2016-05-17 21:47:03,675 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:03,676 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:06,815 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:03.112
2016-05-17 21:47:06,821 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:47:06,821 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:07,045 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] starting
2016-05-17 21:47:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 21:47:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testDeepPipeline/deeppipline"]
2016-05-17 21:47:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  parallel execution of steps is enabled: false
2016-05-17 21:47:07,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  executing total steps: 1
2016-05-17 21:47:07,048 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  allocating management threads: 1
2016-05-17 21:47:07,049 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] starting step: (1/1) ...tDeepPipeline/deeppipline
2016-05-17 21:47:07,079 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] submitted hadoop job: job_local_0014
2016-05-17 21:47:07,080 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline] tracking url: http://localhost:8080/
2016-05-17 21:47:07,084 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt
2016-05-17 21:47:07,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:07,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:07,474 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C000BC0BEB164CAD9D422D73938200D5, ordinal: 0
2016-05-17 21:47:07,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache.200.txt"]
2016-05-17 21:47:07,504 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2016-05-17 21:47:07,504 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C000BC0BEB164CAD9D422D73938200D5, mem on start (mb), free: 136, total: 248, max: 672
2016-05-17 21:47:07,733 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C000BC0BEB164CAD9D422D73938200D5, mem on close (mb), free: 128, total: 248, max: 672
2016-05-17 21:47:10,088 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:47:10,088 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:47:10,162 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FF5168A7C6DD4622A9ED530A371CDECA, ordinal: 1
2016-05-17 21:47:10,180 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2016-05-17 21:47:10,180 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testDeepPipeline/deeppipline"]
2016-05-17 21:47:10,180 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FF5168A7C6DD4622A9ED530A371CDECA, mem on start (mb), free: 123, total: 248, max: 672
2016-05-17 21:47:10,540 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FF5168A7C6DD4622A9ED530A371CDECA, mem on close (mb), free: 116, total: 248, max: 672
2016-05-17 21:47:13,096 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testDeepPipeline/deeppipline/_temporary
2016-05-17 21:47:13,097 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipeline]  completed in: 00:06.051
2016-05-17 21:47:13,110 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testDeepPipeline/deeppipline
2016-05-17 21:47:13,119 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:13,119 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:13,141 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-17 21:47:13,142 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:47:13,142 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:13,151 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] starting
2016-05-17 21:47:13,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:47:13,153 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  sink: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2016-05-17 21:47:13,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  parallel execution of steps is enabled: false
2016-05-17 21:47:13,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  executing total steps: 1
2016-05-17 21:47:13,154 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  allocating management threads: 1
2016-05-17 21:47:13,156 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] starting step: (1/1) ...litPipe/splitintermediate
2016-05-17 21:47:13,186 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] submitted hadoop job: job_local_0015
2016-05-17 21:47:13,188 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split] tracking url: http://localhost:8080/
2016-05-17 21:47:13,191 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt
2016-05-17 21:47:13,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:13,194 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:13,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DA1864816E14440088B81DA9AF2E41A0, ordinal: 0
2016-05-17 21:47:13,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower.txt"]
2016-05-17 21:47:13,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2016-05-17 21:47:13,198 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1864816E14440088B81DA9AF2E41A0, mem on start (mb), free: 106, total: 248, max: 672
2016-05-17 21:47:13,199 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DA1864816E14440088B81DA9AF2E41A0, mem on close (mb), free: 106, total: 248, max: 672
2016-05-17 21:47:16,195 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/_temporary
2016-05-17 21:47:16,196 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [split]  completed in: 00:03.044
2016-05-17 21:47:16,202 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:16,203 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:16,233 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-17 21:47:16,234 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 21:47:16,235 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:16,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting
2016-05-17 21:47:16,246 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2016-05-17 21:47:16,247 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2016-05-17 21:47:16,247 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  parallel execution of steps is enabled: false
2016-05-17 21:47:16,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  executing total steps: 1
2016-05-17 21:47:16,248 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  allocating management threads: 1
2016-05-17 21:47:16,249 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] starting step: (1/1) ...pBySplitPipe/groupbysplit
2016-05-17 21:47:16,270 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] submitted hadoop job: job_local_0016
2016-05-17 21:47:16,271 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs] tracking url: http://localhost:8080/
2016-05-17 21:47:16,275 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/part-00000
2016-05-17 21:47:16,367 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:16,367 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:16,371 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BBB221585EFC476EBBC5850F76D546DE, ordinal: 0
2016-05-17 21:47:16,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2016-05-17 21:47:16,372 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2016-05-17 21:47:16,373 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBB221585EFC476EBBC5850F76D546DE, mem on start (mb), free: 92, total: 343, max: 672
2016-05-17 21:47:16,375 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BBB221585EFC476EBBC5850F76D546DE, mem on close (mb), free: 92, total: 343, max: 672
2016-05-17 21:47:19,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:47:19,281 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:47:19,285 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F2515B0C9C9B495A87E92ABA33FF41C6, ordinal: 1
2016-05-17 21:47:19,286 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2016-05-17 21:47:19,286 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2016-05-17 21:47:19,286 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2515B0C9C9B495A87E92ABA33FF41C6, mem on start (mb), free: 91, total: 343, max: 672
2016-05-17 21:47:19,291 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F2515B0C9C9B495A87E92ABA33FF41C6, mem on close (mb), free: 91, total: 343, max: 672
2016-05-17 21:47:22,287 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testGroupBySplitPipe/groupbysplit/_temporary
2016-05-17 21:47:22,287 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs+rhs]  completed in: 00:06.040
2016-05-17 21:47:22,313 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testGroupBySplitPipe/splitintermediate
2016-05-17 21:47:22,313 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testGroupBySplitPipe/groupbysplit
2016-05-17 21:47:22,321 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:22,322 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:22,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-05-17 21:47:22,368 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2016-05-17 21:47:22,369 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:22,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] starting
2016-05-17 21:47:22,394 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:47:22,395 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2016-05-17 21:47:22,395 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  parallel execution of steps is enabled: false
2016-05-17 21:47:22,396 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  executing total steps: 2
2016-05-17 21:47:22,396 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  allocating management threads: 1
2016-05-17 21:47:22,397 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2016-05-17 21:47:22,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0017
2016-05-17 21:47:22,420 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2016-05-17 21:47:22,423 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:47:22,515 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:22,516 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:22,520 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E5B7D9A75FBA4E02857E6D9C90C2F35C, ordinal: 0
2016-05-17 21:47:22,521 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:47:22,521 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2016-05-17 21:47:22,521 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5B7D9A75FBA4E02857E6D9C90C2F35C, mem on start (mb), free: 156, total: 472, max: 672
2016-05-17 21:47:22,522 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E5B7D9A75FBA4E02857E6D9C90C2F35C, mem on close (mb), free: 155, total: 472, max: 672
2016-05-17 21:47:25,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:47:25,427 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:47:25,432 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D034A3B9DD604174BCCB33C6022D4622, ordinal: 1
2016-05-17 21:47:25,433 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2016-05-17 21:47:25,433 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][8616462838/__&%&%bar:bar@foo:_blah_/]
2016-05-17 21:47:25,433 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D034A3B9DD604174BCCB33C6022D4622, mem on start (mb), free: 154, total: 472, max: 672
2016-05-17 21:47:25,444 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D034A3B9DD604174BCCB33C6022D4622, mem on close (mb), free: 153, total: 472, max: 672
2016-05-17 21:47:28,434 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...sInTempFiles/illegalchars
2016-05-17 21:47:28,456 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local_0018
2016-05-17 21:47:28,458 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2016-05-17 21:47:28,461 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/8616462838____bar_bar_foo__blah__846E611A67B349B78FC2E916DFB5C623/part-00000
2016-05-17 21:47:28,558 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:28,558 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:28,562 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB0FF40150E54A92A4A4ADCCE0F4058B, ordinal: 0
2016-05-17 21:47:28,563 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][8616462838/__&%&%bar:bar@foo:_blah_/]
2016-05-17 21:47:28,564 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2016-05-17 21:47:28,564 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB0FF40150E54A92A4A4ADCCE0F4058B, mem on start (mb), free: 144, total: 568, max: 672
2016-05-17 21:47:28,566 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB0FF40150E54A92A4A4ADCCE0F4058B, mem on close (mb), free: 144, total: 568, max: 672
2016-05-17 21:47:31,466 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 21:47:31,466 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 21:47:31,470 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A59E4B1E3A93400BA93025BA99F5006E, ordinal: 1
2016-05-17 21:47:31,472 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2016-05-17 21:47:31,472 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2016-05-17 21:47:31,472 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A59E4B1E3A93400BA93025BA99F5006E, mem on start (mb), free: 143, total: 568, max: 672
2016-05-17 21:47:31,479 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A59E4B1E3A93400BA93025BA99F5006E, mem on close (mb), free: 142, total: 568, max: 672
2016-05-17 21:47:34,470 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars/_temporary
2016-05-17 21:47:34,471 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [**&%&%bar:bar@foo://bl...]  completed in: 00:12.075
2016-05-17 21:47:34,477 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars
2016-05-17 21:47:34,485 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 21:47:34,485 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 21:47:34,503 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-05-17 21:47:34,504 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 21:47:34,504 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 21:47:34,510 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 21:47:34,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:47:34,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2016-05-17 21:47:34,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 21:47:34,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 21:47:34,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 21:47:34,512 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2016-05-17 21:47:34,532 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local_0019
2016-05-17 21:47:34,533 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 21:47:34,536 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt
2016-05-17 21:47:34,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 21:47:34,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 21:47:34,546 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB4EF733E27F41659DC867C206DE045F, ordinal: 0
2016-05-17 21:47:34,547 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/lower+upper.txt"]
2016-05-17 21:47:34,547 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2016-05-17 21:47:34,547 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB4EF733E27F41659DC867C206DE045F, mem on start (mb), free: 132, total: 568, max: 672
2016-05-17 21:47:34,549 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB4EF733E27F41659DC867C206DE045F, mem on close (mb), free: 132, total: 568, max: 672
2016-05-17 21:47:37,547 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic/_temporary
2016-05-17 21:47:37,548 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:03.037
2016-05-17 21:47:37,554 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic

Standard error

rhs-pre: ['num', 'char']
rhs-pre: ['1', 'a']
rhs-post: ['num2']
rhs-post: ['1']
rhs-pre: ['2', 'b']
rhs-post: ['2']
rhs-pre: ['3', 'c']
rhs-post: ['3']
rhs-pre: ['4', 'd']
rhs-post: ['4']
rhs-pre: ['5', 'e']
rhs-post: ['5']
rhs-pre: tuples count: 5
rhs-post: tuples count: 5
cascading.flow.FlowException: local step failed: (1/1) .../testOOMEPreGroup/oomepre
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:293)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
cascading.flow.FlowException: local step failed: (1/1) ...estOOMEPostGroup/oomepost
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:293)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)