Class cascading.RegressionPipesPlatformTest

18

tests

0

failures

0

ignored

11.192s

duration

100%

successful

Tests

Test Duration Result
testCoGroupSplitPipe 1.026s passed
testComplexLogicAnd 0.339s passed
testComplexLogicOr 2.001s passed
testComplexLogicXor 0.282s passed
testCopy 0.308s passed
testDeepPipeline 3.448s passed
testDupeHeadNames 0.020s passed
testDupeTailNames 0.022s passed
testGroupBySplitPipe 0.532s passed
testGroupNoneSortUnknown 0.446s passed
testIllegalCharsInTempFiles 0.534s passed
testLastEachNotModified 0.348s passed
testOOMEPostGroup 0.422s passed
testOOMEPreGroup 0.291s passed
testUnGroupUnknown 0.218s passed
testUnknown 0.254s passed
testUnknownReplace 0.443s passed
testVarWidth 0.258s passed

Standard output

2015-07-21 11:57:59,432 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 11:57:59,461 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.RegressionPipesPlatformTest, with platform: hadoop2-mr1
2015-07-21 11:57:59,493 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-07-21 11:58:00,085 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-21 11:58:00,203 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-07-21 11:58:00,322 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:00,323 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:00,419 INFO  property.AppProps (AppProps.java:getAppID(174)) - using app.id: 0C79F38163BF4599B20F9FA83DFDD1DE
2015-07-21 11:58:00,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2015-07-21 11:58:00,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:00,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:00,691 INFO  util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 11:58:00,692 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:00,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:00,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2015-07-21 11:58:00,693 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:00,695 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:00,695 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:00,696 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...regression/complexlogicor
2015-07-21 11:58:01,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local781177374_0001
2015-07-21 11:58:01,247 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:01,315 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt
2015-07-21 11:58:01,350 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:01,350 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:01,362 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9E56F71AD7D4EF3B33D6B6F0E2235BE, ordinal: 0
2015-07-21 11:58:01,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:01,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2015-07-21 11:58:01,391 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9E56F71AD7D4EF3B33D6B6F0E2235BE, mem on start (mb), free: 229, total: 245, max: 672
2015-07-21 11:58:01,406 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9E56F71AD7D4EF3B33D6B6F0E2235BE, mem on close (mb), free: 228, total: 245, max: 672
2015-07-21 11:58:01,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor/_temporary
2015-07-21 11:58:01,453 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.759
2015-07-21 11:58:01,490 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor
2015-07-21 11:58:01,516 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:01,517 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:01,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-07-21 11:58:01,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:01,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting
2015-07-21 11:58:01,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:01,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  sink: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-07-21 11:58:01,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  parallel execution of steps is enabled: false
2015-07-21 11:58:01,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  executing total steps: 1
2015-07-21 11:58:01,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  allocating management threads: 1
2015-07-21 11:58:01,581 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting step: (1/1) ...oupSplitPipe/intermediate
2015-07-21 11:58:01,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] submitted hadoop job: job_local848241488_0002
2015-07-21 11:58:01,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] tracking url: http://localhost:8080/
2015-07-21 11:58:01,752 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt
2015-07-21 11:58:01,763 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:01,763 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:01,770 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6E590BA8EDD4F1C915E459DA539BEEA, ordinal: 0
2015-07-21 11:58:01,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:01,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-07-21 11:58:01,772 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6E590BA8EDD4F1C915E459DA539BEEA, mem on start (mb), free: 172, total: 245, max: 672
2015-07-21 11:58:01,774 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6E590BA8EDD4F1C915E459DA539BEEA, mem on close (mb), free: 172, total: 245, max: 672
2015-07-21 11:58:01,810 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate/_temporary
2015-07-21 11:58:01,810 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  completed in: 00:00.230
2015-07-21 11:58:01,841 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:01,842 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:01,907 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2015-07-21 11:58:01,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:01,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:01,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-07-21 11:58:01,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-07-21 11:58:01,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2015-07-21 11:58:01,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: false
2015-07-21 11:58:01,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 1
2015-07-21 11:58:01,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 1
2015-07-21 11:58:01,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...oupSplitPipe/cogroupsplit
2015-07-21 11:58:02,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_local894386690_0003
2015-07-21 11:58:02,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:8080/
2015-07-21 11:58:02,168 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate/part-00000
2015-07-21 11:58:02,251 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:02,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:02,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F16C5E9BCBAF464088576DD053DD720E, ordinal: 0
2015-07-21 11:58:02,267 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-07-21 11:58:02,267 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-07-21 11:58:02,267 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F16C5E9BCBAF464088576DD053DD720E, mem on start (mb), free: 142, total: 310, max: 672
2015-07-21 11:58:02,271 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F16C5E9BCBAF464088576DD053DD720E, mem on close (mb), free: 141, total: 310, max: 672
2015-07-21 11:58:02,372 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:02,372 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:02,381 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EA7C7E9B5C814274BBD5D6DE21A0DC24, ordinal: 1
2015-07-21 11:58:02,383 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-07-21 11:58:02,383 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2015-07-21 11:58:02,384 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA7C7E9B5C814274BBD5D6DE21A0DC24, mem on start (mb), free: 127, total: 310, max: 672
2015-07-21 11:58:02,402 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-21 11:58:02,402 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-21 11:58:02,412 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EA7C7E9B5C814274BBD5D6DE21A0DC24, mem on close (mb), free: 124, total: 310, max: 672
2015-07-21 11:58:02,439 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit/_temporary
2015-07-21 11:58:02,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 00:00.486
2015-07-21 11:58:02,519 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit
2015-07-21 11:58:02,519 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate
2015-07-21 11:58:02,544 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:02,545 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:02,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2015-07-21 11:58:02,598 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:02,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:02,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:02,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:02,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2015-07-21 11:58:02,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:02,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:02,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:02,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...eSortUnknown/none-unknown
2015-07-21 11:58:02,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local194120104_0004
2015-07-21 11:58:02,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:02,833 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:02,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:02,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:02,856 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF4DF650EFCE43AC8DE2C038796B23E5, ordinal: 0
2015-07-21 11:58:02,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:02,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2015-07-21 11:58:02,857 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF4DF650EFCE43AC8DE2C038796B23E5, mem on start (mb), free: 85, total: 310, max: 672
2015-07-21 11:58:02,859 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF4DF650EFCE43AC8DE2C038796B23E5, mem on close (mb), free: 85, total: 310, max: 672
2015-07-21 11:58:02,872 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:02,872 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:02,879 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EBA7B176F02F473E923E850235336CE9, ordinal: 1
2015-07-21 11:58:02,879 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2015-07-21 11:58:02,880 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2015-07-21 11:58:02,880 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBA7B176F02F473E923E850235336CE9, mem on start (mb), free: 82, total: 310, max: 672
2015-07-21 11:58:02,893 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBA7B176F02F473E923E850235336CE9, mem on close (mb), free: 80, total: 310, max: 672
2015-07-21 11:58:02,917 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown/_temporary
2015-07-21 11:58:02,917 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.290
2015-07-21 11:58:02,966 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown
2015-07-21 11:58:02,991 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:02,992 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:03,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 11:58:03,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:03,021 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:03,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:03,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:58:03,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2015-07-21 11:58:03,040 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:03,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:03,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:03,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) .../testOOMEPreGroup/oomepre
2015-07-21 11:58:03,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local373123001_0005
2015-07-21 11:58:03,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:03,213 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 11:58:03,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:03,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:03,232 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF255E95272E41AAA19EFA4CDF2C699D, ordinal: 0
2015-07-21 11:58:03,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:58:03,233 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2015-07-21 11:58:03,233 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF255E95272E41AAA19EFA4CDF2C699D, mem on start (mb), free: 238, total: 411, max: 672
2015-07-21 11:58:03,235 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:74)
	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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-21 11:58:03,237 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF255E95272E41AAA19EFA4CDF2C699D, mem on close (mb), free: 238, total: 411, max: 672
2015-07-21 11:58:03,239 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local373123001_0005
java.lang.Exception: java.lang.OutOfMemoryError: fake error
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$1.throwIntentionalException(RegressionPipesPlatformTest.java:583)
	at cascading.TestFunction.operate(TestFunction.java:74)
	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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-21 11:58:03,244 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local373123001_0005 state at FAILED
2015-07-21 11:58:03,248 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-07-21 11:58:03,251 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-07-21 11:58:03,251 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-07-21 11:58:03,252 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-07-21 11:58:03,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) .../testOOMEPreGroup/oomepre
2015-07-21 11:58:03,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-07-21 11:58:03,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2015-07-21 11:58:03,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2015-07-21 11:58:03,255 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre/_temporary
2015-07-21 11:58:03,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.215
exception = cascading.flow.FlowException: local step failed: (1/1) .../testOOMEPreGroup/oomepre
2015-07-21 11:58:03,257 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre
2015-07-21 11:58:03,278 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:03,279 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:03,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-07-21 11:58:03,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:03,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:03,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:03,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:03,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy"]
2015-07-21 11:58:03,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:03,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:03,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:03,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2015-07-21 11:58:03,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local18423199_0006
2015-07-21 11:58:03,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:03,465 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:03,487 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:03,487 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:03,491 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D476E6F9D1ED46B2AEB0541CF4CF0085, ordinal: 0
2015-07-21 11:58:03,492 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:03,492 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy"]
2015-07-21 11:58:03,492 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D476E6F9D1ED46B2AEB0541CF4CF0085, mem on start (mb), free: 170, total: 411, max: 672
2015-07-21 11:58:03,494 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D476E6F9D1ED46B2AEB0541CF4CF0085, mem on close (mb), free: 170, total: 411, max: 672
2015-07-21 11:58:03,521 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy/_temporary
2015-07-21 11:58:03,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.203
2015-07-21 11:58:03,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testCopy/copy
2015-07-21 11:58:03,610 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:03,613 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:03,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-07-21 11:58:03,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:03,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:03,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:03,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:03,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2015-07-21 11:58:03,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:03,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:03,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:03,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...wnReplace/unknown-replace
2015-07-21 11:58:03,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local366476774_0007
2015-07-21 11:58:03,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:03,878 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:03,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:03,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:03,897 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD3280B65678403FA33862FA191064B0, ordinal: 0
2015-07-21 11:58:03,897 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:03,898 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2015-07-21 11:58:03,898 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD3280B65678403FA33862FA191064B0, mem on start (mb), free: 96, total: 411, max: 672
2015-07-21 11:58:03,899 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD3280B65678403FA33862FA191064B0, mem on close (mb), free: 96, total: 411, max: 672
2015-07-21 11:58:03,933 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace/_temporary
2015-07-21 11:58:03,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.245
2015-07-21 11:58:04,009 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace
2015-07-21 11:58:04,055 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:04,056 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:04,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-07-21 11:58:04,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:04,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:04,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:04,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:04,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2015-07-21 11:58:04,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:04,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:04,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:04,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...egression/complexlogicand
2015-07-21 11:58:04,264 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local398112307_0008
2015-07-21 11:58:04,265 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:04,268 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt
2015-07-21 11:58:04,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:04,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:04,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA8522257505428087E10B26216AFD84, ordinal: 0
2015-07-21 11:58:04,288 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:04,288 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2015-07-21 11:58:04,288 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA8522257505428087E10B26216AFD84, mem on start (mb), free: 244, total: 411, max: 672
2015-07-21 11:58:04,290 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA8522257505428087E10B26216AFD84, mem on close (mb), free: 244, total: 411, max: 672
2015-07-21 11:58:04,313 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand/_temporary
2015-07-21 11:58:04,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.200
2015-07-21 11:58:04,348 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand
2015-07-21 11:58:04,372 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:04,372 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:04,399 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 11:58:04,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:04,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:04,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:04,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...egression/complexlogicxor
2015-07-21 11:58:04,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1129208854_0009
2015-07-21 11:58:04,553 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:04,557 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt
2015-07-21 11:58:04,571 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:04,572 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:04,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6062191E2154281904A3AA0CE9A20D4, ordinal: 0
2015-07-21 11:58:04,578 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:58:04,579 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2015-07-21 11:58:04,579 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6062191E2154281904A3AA0CE9A20D4, mem on start (mb), free: 169, total: 411, max: 672
2015-07-21 11:58:04,581 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6062191E2154281904A3AA0CE9A20D4, mem on close (mb), free: 169, total: 411, max: 672
2015-07-21 11:58:04,602 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor/_temporary
2015-07-21 11:58:04,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.181
2015-07-21 11:58:04,630 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor
2015-07-21 11:58:04,653 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:04,654 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:04,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2015-07-21 11:58:04,734 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:04,735 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:04,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:58:04,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:58:04,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:04,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2015-07-21 11:58:04,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: false
2015-07-21 11:58:04,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-07-21 11:58:04,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-07-21 11:58:04,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estOOMEPostGroup/oomepost
2015-07-21 11:58:04,911 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local988840356_0010
2015-07-21 11:58:04,911 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2015-07-21 11:58:04,915 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt
2015-07-21 11:58:04,940 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:04,941 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:04,947 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, ordinal: 0
2015-07-21 11:58:04,948 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:04,948 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-07-21 11:58:04,948 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, mem on start (mb), free: 199, total: 411, max: 672
2015-07-21 11:58:04,950 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, mem on close (mb), free: 199, total: 411, max: 672
2015-07-21 11:58:04,959 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt
2015-07-21 11:58:04,984 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:04,985 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:04,991 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, ordinal: 0
2015-07-21 11:58:04,992 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:58:04,992 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-07-21 11:58:04,992 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, mem on start (mb), free: 97, total: 411, max: 672
2015-07-21 11:58:04,994 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D18BD1E9D5F547D4A85A59C54D4078AB, mem on close (mb), free: 97, total: 411, max: 672
2015-07-21 11:58:05,009 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:05,009 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:05,014 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E28BD311114549798B5D501FE88F30CE, ordinal: 1
2015-07-21 11:58:05,015 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-07-21 11:58:05,015 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2015-07-21 11:58:05,015 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E28BD311114549798B5D501FE88F30CE, mem on start (mb), free: 90, total: 411, max: 672
2015-07-21 11:58:05,025 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-21 11:58:05,026 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-07-21 11:58:05,026 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:74)
	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:141)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-21 11:58:05,028 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E28BD311114549798B5D501FE88F30CE, mem on close (mb), free: 88, total: 411, max: 672
2015-07-21 11:58:05,033 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local988840356_0010
java.lang.Exception: java.lang.OutOfMemoryError: fake error
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:529)
Caused by: java.lang.OutOfMemoryError: fake error
	at cascading.RegressionPipesPlatformTest$2.throwIntentionalException(RegressionPipesPlatformTest.java:635)
	at cascading.TestFunction.operate(TestFunction.java:74)
	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:141)
	at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:146)
	at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:444)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:392)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$ReduceTaskRunnable.run(LocalJobRunner.java:319)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2015-07-21 11:58:05,043 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_local988840356_0010 state at FAILED
2015-07-21 11:58:05,043 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: NA
2015-07-21 11:58:05,043 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2015-07-21 11:58:05,044 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 0
2015-07-21 11:58:05,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-07-21 11:58:05,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/1) ...estOOMEPostGroup/oomepost
2015-07-21 11:58:05,050 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-07-21 11:58:05,051 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost/_temporary
2015-07-21 11:58:05,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 00:00.282
exception = cascading.flow.FlowException: local step failed: (1/1) ...estOOMEPostGroup/oomepost
2015-07-21 11:58:05,053 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost
2015-07-21 11:58:05,068 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:05,069 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:05,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-07-21 11:58:05,101 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:05,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:05,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:05,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:58:05,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2015-07-21 11:58:05,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:05,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:05,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:05,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Modified/lasteachmodified
2015-07-21 11:58:05,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1604819749_0011
2015-07-21 11:58:05,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:05,269 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt
2015-07-21 11:58:05,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:05,283 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:05,288 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AF6E337A8F344303A930FE8FC2FAE08D, ordinal: 0
2015-07-21 11:58:05,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:58:05,289 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2015-07-21 11:58:05,289 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6E337A8F344303A930FE8FC2FAE08D, mem on start (mb), free: 152, total: 402, max: 672
2015-07-21 11:58:05,291 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AF6E337A8F344303A930FE8FC2FAE08D, mem on close (mb), free: 152, total: 402, max: 672
2015-07-21 11:58:05,308 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:05,308 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:05,316 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A642F228D2FD45D2BF00ECF852F8810A, ordinal: 1
2015-07-21 11:58:05,317 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2015-07-21 11:58:05,317 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2015-07-21 11:58:05,317 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A642F228D2FD45D2BF00ECF852F8810A, mem on start (mb), free: 146, total: 402, max: 672
2015-07-21 11:58:05,336 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A642F228D2FD45D2BF00ECF852F8810A, mem on close (mb), free: 144, total: 402, max: 672
2015-07-21 11:58:05,367 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified/_temporary
2015-07-21 11:58:05,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.251
2015-07-21 11:58:05,401 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified
2015-07-21 11:58:05,420 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:05,420 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:05,445 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 11:58:05,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:05,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:05,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:05,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:05,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown"]
2015-07-21 11:58:05,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:05,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:05,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:05,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testUnknown/unknown
2015-07-21 11:58:05,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local581103334_0012
2015-07-21 11:58:05,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:05,583 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:05,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:05,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:05,597 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D206C556A4FE4892B875447660F2A9D8, ordinal: 0
2015-07-21 11:58:05,598 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:05,598 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown"]
2015-07-21 11:58:05,598 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D206C556A4FE4892B875447660F2A9D8, mem on start (mb), free: 75, total: 402, max: 672
2015-07-21 11:58:05,599 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D206C556A4FE4892B875447660F2A9D8, mem on close (mb), free: 75, total: 402, max: 672
2015-07-21 11:58:05,617 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown/_temporary
2015-07-21 11:58:05,617 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.155
2015-07-21 11:58:05,656 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnknown/unknown
2015-07-21 11:58:05,679 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:05,680 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:05,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 11:58:05,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:05,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:05,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:05,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/critics.txt"]
2015-07-21 11:58:05,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth"]
2015-07-21 11:58:05,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:05,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:05,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:05,719 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testVarWidth/varwidth
2015-07-21 11:58:05,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local696937752_0013
2015-07-21 11:58:05,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:05,844 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/critics.txt
2015-07-21 11:58:05,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:05,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:05,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A52418211DA14985B3165158D15BB8FB, ordinal: 0
2015-07-21 11:58:05,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/critics.txt"]
2015-07-21 11:58:05,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth"]
2015-07-21 11:58:05,858 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52418211DA14985B3165158D15BB8FB, mem on start (mb), free: 235, total: 410, max: 672
2015-07-21 11:58:05,860 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A52418211DA14985B3165158D15BB8FB, mem on close (mb), free: 235, total: 410, max: 672
2015-07-21 11:58:05,884 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth/_temporary
2015-07-21 11:58:05,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.167
2015-07-21 11:58:05,914 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth
2015-07-21 11:58:05,931 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:05,931 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:05,934 WARN  planner.FlowPlanner (FlowPlanner.java:verifyPipeAssemblyEndPoints(463)) - duplicate head name found, not an error but heads should have unique names: 'test'
2015-07-21 11:58:05,935 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testDupeHeadNames/unknown
2015-07-21 11:58:05,953 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:05,954 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:05,956 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testDupeTailNames/unknown
2015-07-21 11:58:06,179 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:06,179 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:08,430 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:02.236
2015-07-21 11:58:08,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:08,433 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:08,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] starting
2015-07-21 11:58:08,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.200.txt"]
2015-07-21 11:58:08,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline"]
2015-07-21 11:58:08,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  parallel execution of steps is enabled: false
2015-07-21 11:58:08,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  executing total steps: 1
2015-07-21 11:58:08,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  allocating management threads: 1
2015-07-21 11:58:08,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] starting step: (1/1) ...tDeepPipeline/deeppipline
2015-07-21 11:58:08,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] submitted hadoop job: job_local820773684_0014
2015-07-21 11:58:08,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] tracking url: http://localhost:8080/
2015-07-21 11:58:08,706 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.200.txt
2015-07-21 11:58:08,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:08,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:08,801 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D85856F037B24CE9BE430F9D3B628637, ordinal: 0
2015-07-21 11:58:08,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.200.txt"]
2015-07-21 11:58:08,820 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2015-07-21 11:58:08,820 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D85856F037B24CE9BE430F9D3B628637, mem on start (mb), free: 99, total: 404, max: 672
2015-07-21 11:58:08,976 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D85856F037B24CE9BE430F9D3B628637, mem on close (mb), free: 87, total: 404, max: 672
2015-07-21 11:58:09,000 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:09,000 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:09,061 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EC1A67D3F8804115960F6A81E8E27543, ordinal: 1
2015-07-21 11:58:09,076 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2015-07-21 11:58:09,076 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline"]
2015-07-21 11:58:09,076 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC1A67D3F8804115960F6A81E8E27543, mem on start (mb), free: 76, total: 404, max: 672
2015-07-21 11:58:09,327 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC1A67D3F8804115960F6A81E8E27543, mem on close (mb), free: 64, total: 404, max: 672
2015-07-21 11:58:09,369 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline/_temporary
2015-07-21 11:58:09,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline]  completed in: 00:00.795
2015-07-21 11:58:09,405 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline
2015-07-21 11:58:09,422 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:09,422 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:09,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-07-21 11:58:09,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:09,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  sink: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  parallel execution of steps is enabled: false
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  executing total steps: 1
2015-07-21 11:58:09,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  allocating management threads: 1
2015-07-21 11:58:09,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting step: (1/1) ...litPipe/splitintermediate
2015-07-21 11:58:09,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] submitted hadoop job: job_local181551982_0015
2015-07-21 11:58:09,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split] tracking url: http://localhost:8080/
2015-07-21 11:58:09,577 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt
2015-07-21 11:58:09,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:09,587 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:09,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3E04A350A274D729D29FFE333730309, ordinal: 0
2015-07-21 11:58:09,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:58:09,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-07-21 11:58:09,591 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E04A350A274D729D29FFE333730309, mem on start (mb), free: 230, total: 410, max: 672
2015-07-21 11:58:09,592 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3E04A350A274D729D29FFE333730309, mem on close (mb), free: 230, total: 410, max: 672
2015-07-21 11:58:09,607 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/_temporary
2015-07-21 11:58:09,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [split]  completed in: 00:00.158
2015-07-21 11:58:09,625 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:09,625 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:09,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2015-07-21 11:58:09,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:58:09,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:09,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-07-21 11:58:09,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-07-21 11:58:09,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2015-07-21 11:58:09,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  parallel execution of steps is enabled: false
2015-07-21 11:58:09,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  executing total steps: 1
2015-07-21 11:58:09,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  allocating management threads: 1
2015-07-21 11:58:09,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/1) ...pBySplitPipe/groupbysplit
2015-07-21 11:58:09,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_local400915322_0016
2015-07-21 11:58:09,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:8080/
2015-07-21 11:58:09,811 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/part-00000
2015-07-21 11:58:09,828 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:09,828 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:09,831 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D758B9DEDB854A0FACFB7EC66272328A, ordinal: 0
2015-07-21 11:58:09,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-07-21 11:58:09,832 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-07-21 11:58:09,832 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D758B9DEDB854A0FACFB7EC66272328A, mem on start (mb), free: 194, total: 410, max: 672
2015-07-21 11:58:09,833 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D758B9DEDB854A0FACFB7EC66272328A, mem on close (mb), free: 194, total: 410, max: 672
2015-07-21 11:58:09,843 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:09,843 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:09,847 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E9E51A28281E4A52B564D55F4171F5EA, ordinal: 1
2015-07-21 11:58:09,847 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-07-21 11:58:09,847 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2015-07-21 11:58:09,848 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E9E51A28281E4A52B564D55F4171F5EA, mem on start (mb), free: 188, total: 410, max: 672
2015-07-21 11:58:09,863 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E9E51A28281E4A52B564D55F4171F5EA, mem on close (mb), free: 186, total: 410, max: 672
2015-07-21 11:58:09,881 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit/_temporary
2015-07-21 11:58:09,881 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  completed in: 00:00.226
2015-07-21 11:58:09,938 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate
2015-07-21 11:58:09,938 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit
2015-07-21 11:58:09,950 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:09,950 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:09,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 11:58:09,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:58:09,993 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:10,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting
2015-07-21 11:58:10,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:10,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2015-07-21 11:58:10,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  parallel execution of steps is enabled: false
2015-07-21 11:58:10,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  executing total steps: 2
2015-07-21 11:58:10,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  allocating management threads: 1
2015-07-21 11:58:10,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2015-07-21 11:58:10,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local1767427965_0017
2015-07-21 11:58:10,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-07-21 11:58:10,141 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:10,159 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:10,159 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:10,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F2E06FC90C3B48A19BFC9237F7E04F15, ordinal: 0
2015-07-21 11:58:10,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:10,164 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2015-07-21 11:58:10,164 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F2E06FC90C3B48A19BFC9237F7E04F15, mem on start (mb), free: 196, total: 411, max: 672
2015-07-21 11:58:10,165 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F2E06FC90C3B48A19BFC9237F7E04F15, mem on close (mb), free: 196, total: 411, max: 672
2015-07-21 11:58:10,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:10,176 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:10,180 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E3549055ADE8467E8AE5FBA8486ABCF3, ordinal: 1
2015-07-21 11:58:10,181 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2015-07-21 11:58:10,181 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][8809595666/__&%&%bar:bar@foo:_blah_/]
2015-07-21 11:58:10,181 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3549055ADE8467E8AE5FBA8486ABCF3, mem on start (mb), free: 189, total: 411, max: 672
2015-07-21 11:58:10,205 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E3549055ADE8467E8AE5FBA8486ABCF3, mem on close (mb), free: 187, total: 411, max: 672
2015-07-21 11:58:10,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...sInTempFiles/illegalchars
2015-07-21 11:58:10,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local201654807_0018
2015-07-21 11:58:10,364 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-07-21 11:58:10,367 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-castillo/8809595666____bar_bar_foo__blah__B91B4B1DFB404C7C8E6A3F87293B0047/part-00000
2015-07-21 11:58:10,388 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:10,388 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:10,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EC94C854FE6F4ECB81804EA32CBB19C0, ordinal: 0
2015-07-21 11:58:10,391 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][8809595666/__&%&%bar:bar@foo:_blah_/]
2015-07-21 11:58:10,391 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2015-07-21 11:58:10,391 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC94C854FE6F4ECB81804EA32CBB19C0, mem on start (mb), free: 195, total: 411, max: 672
2015-07-21 11:58:10,392 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EC94C854FE6F4ECB81804EA32CBB19C0, mem on close (mb), free: 195, total: 411, max: 672
2015-07-21 11:58:10,402 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.1
2015-07-21 11:58:10,402 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-07-21 11:58:10,406 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C31B997E53C34C24B2EACF6BBABC4CED, ordinal: 1
2015-07-21 11:58:10,406 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/	(*(**^**&%&%^@#@&&() :::: ///\\ 	 illegal chars in it)[by:[{1}:0]]
2015-07-21 11:58:10,407 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2015-07-21 11:58:10,407 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C31B997E53C34C24B2EACF6BBABC4CED, mem on start (mb), free: 189, total: 411, max: 672
2015-07-21 11:58:10,420 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C31B997E53C34C24B2EACF6BBABC4CED, mem on close (mb), free: 187, total: 411, max: 672
2015-07-21 11:58:10,447 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars/_temporary
2015-07-21 11:58:10,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...]  completed in: 00:00.427
2015-07-21 11:58:10,472 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars
2015-07-21 11:58:10,485 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:58:10,486 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:58:10,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.011
2015-07-21 11:58:10,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:58:10,501 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:58:10,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:58:10,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:10,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2015-07-21 11:58:10,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: false
2015-07-21 11:58:10,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:58:10,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:58:10,511 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2015-07-21 11:58:10,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1456590686_0019
2015-07-21 11:58:10,623 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-07-21 11:58:10,626 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt
2015-07-21 11:58:10,635 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 11:58:10,635 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 11:58:10,638 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E855D266C8D3475692A18C60524AFB42, ordinal: 0
2015-07-21 11:58:10,639 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:58:10,640 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2015-07-21 11:58:10,640 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E855D266C8D3475692A18C60524AFB42, mem on start (mb), free: 122, total: 411, max: 672
2015-07-21 11:58:10,641 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E855D266C8D3475692A18C60524AFB42, mem on close (mb), free: 122, total: 411, max: 672
2015-07-21 11:58:10,660 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic/_temporary
2015-07-21 11:58:10,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:00.150
2015-07-21 11:58:10,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
rhs-pre: ['num', 'char']
rhs-pre: ['1', 'a']
rhs-post: ['num2']
rhs-post: ['1']
rhs-pre: ['2', 'b']
rhs-post: ['2']
rhs-pre: ['3', 'c']
rhs-post: ['3']
rhs-pre: ['4', 'd']
rhs-post: ['4']
rhs-pre: ['5', 'e']
rhs-post: ['5']
rhs-pre: tuples count: 5
rhs-post: tuples count: 5
cascading.flow.FlowException: local step failed: (1/1) .../testOOMEPreGroup/oomepre
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:272)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:172)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:134)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:45)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
cascading.flow.FlowException: local step failed: (1/1) ...estOOMEPostGroup/oomepost
	at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:272)
	at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:172)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:134)
	at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:45)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)