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