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