2015-08-12 17:33:29,796 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 17:33:29,839 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.RegressionPipesPlatformTest, with platform: hadoop2-mr1
2015-08-12 17:33:29,904 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 17:33:30,785 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-12 17:33:30,995 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-08-12 17:33:31,214 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:31,217 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:31,345 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: AC17681DE22E40DE94985BD82BD89E49
2015-08-12 17:33:31,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.157
2015-08-12 17:33:31,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:31,574 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-08-12 17:33:31,766 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 17:33:31,768 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:31,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:31,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2015-08-12 17:33:31,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:31,770 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:31,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:31,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...regression/complexlogicor
2015-08-12 17:33:32,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1461440706_0001
2015-08-12 17:33:32,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:32,882 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt
2015-08-12 17:33:32,906 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:32,907 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:32,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5B0BE3507F64D78B109DB1A032A281C, ordinal: 0
2015-08-12 17:33:32,964 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:32,965 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor"]
2015-08-12 17:33:32,967 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B0BE3507F64D78B109DB1A032A281C, mem on start (mb), free: 119, total: 148, max: 672
2015-08-12 17:33:32,981 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5B0BE3507F64D78B109DB1A032A281C, mem on close (mb), free: 117, total: 148, max: 672
2015-08-12 17:33:33,038 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor/_temporary
2015-08-12 17:33:33,038 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:01.268
2015-08-12 17:33:33,084 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicOr/regression/complexlogicor
2015-08-12 17:33:33,134 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:33,136 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:33,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2015-08-12 17:33:33,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:33,217 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-08-12 17:33:33,242 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting
2015-08-12 17:33:33,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:33,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-08-12 17:33:33,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] parallel execution of steps is enabled: false
2015-08-12 17:33:33,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executing total steps: 1
2015-08-12 17:33:33,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] allocating management threads: 1
2015-08-12 17:33:33,250 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting step: (1/1) ...oupSplitPipe/intermediate
2015-08-12 17:33:33,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] submitted hadoop job: job_local2025794381_0002
2015-08-12 17:33:33,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] tracking url: http://localhost:8080/
2015-08-12 17:33:33,505 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt
2015-08-12 17:33:33,517 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:33,517 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:33,531 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F61F139596F84AACAAECC2687F471003, ordinal: 0
2015-08-12 17:33:33,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:33,535 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-08-12 17:33:33,537 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F61F139596F84AACAAECC2687F471003, mem on start (mb), free: 182, total: 212, max: 672
2015-08-12 17:33:33,542 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F61F139596F84AACAAECC2687F471003, mem on close (mb), free: 181, total: 212, max: 672
2015-08-12 17:33:33,593 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate/_temporary
2015-08-12 17:33:33,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] completed in: 00:00.350
2015-08-12 17:33:33,693 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:33,695 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:33,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.121
2015-08-12 17:33:33,837 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:33,838 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-08-12 17:33:33,933 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-08-12 17:33:33,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-08-12 17:33:33,935 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2015-08-12 17:33:33,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: false
2015-08-12 17:33:33,937 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2015-08-12 17:33:33,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2015-08-12 17:33:33,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...oupSplitPipe/cogroupsplit
2015-08-12 17:33:34,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_local1776295154_0003
2015-08-12 17:33:34,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:8080/
2015-08-12 17:33:34,359 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate/part-00000
2015-08-12 17:33:34,444 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:34,444 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:34,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E0EEC6121E30402890475593E1FE3727, ordinal: 0
2015-08-12 17:33:34,471 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate"]
2015-08-12 17:33:34,471 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-08-12 17:33:34,472 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EEC6121E30402890475593E1FE3727, mem on start (mb), free: 120, total: 313, max: 672
2015-08-12 17:33:34,489 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E0EEC6121E30402890475593E1FE3727, mem on close (mb), free: 120, total: 313, max: 672
2015-08-12 17:33:34,692 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:34,693 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:34,718 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: ADA9EDD7E808467C99D1EEBC91C0BBCA, ordinal: 1
2015-08-12 17:33:34,724 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lhs*rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num2']]
2015-08-12 17:33:34,728 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit"]
2015-08-12 17:33:34,730 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADA9EDD7E808467C99D1EEBC91C0BBCA, mem on start (mb), free: 103, total: 313, max: 672
2015-08-12 17:33:34,778 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 17:33:34,782 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 17:33:34,815 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: ADA9EDD7E808467C99D1EEBC91C0BBCA, mem on close (mb), free: 100, total: 313, max: 672
2015-08-12 17:33:34,885 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit/_temporary
2015-08-12 17:33:34,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:00.951
2015-08-12 17:33:35,111 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/intermediate
2015-08-12 17:33:35,113 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testCoGroupSplitPipe/cogroupsplit
2015-08-12 17:33:35,206 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:35,213 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:35,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.108
2015-08-12 17:33:35,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:35,343 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-08-12 17:33:35,450 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:35,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:35,454 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2015-08-12 17:33:35,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:35,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:35,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:35,483 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...eSortUnknown/none-unknown
2015-08-12 17:33:35,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local515321733_0004
2015-08-12 17:33:35,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:35,710 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:35,752 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:35,752 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:35,758 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C4AEB3898A404D808B35EAF85F7B54B9, ordinal: 0
2015-08-12 17:33:35,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:35,760 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{?}:NONE]]
2015-08-12 17:33:35,760 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4AEB3898A404D808B35EAF85F7B54B9, mem on start (mb), free: 156, total: 414, max: 672
2015-08-12 17:33:35,763 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4AEB3898A404D808B35EAF85F7B54B9, mem on close (mb), free: 156, total: 414, max: 672
2015-08-12 17:33:35,787 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:35,787 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:35,797 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D7AC068D00FC4E75B306298474C09B1D, ordinal: 1
2015-08-12 17:33:35,798 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{?}:NONE]]
2015-08-12 17:33:35,799 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown"]
2015-08-12 17:33:35,800 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7AC068D00FC4E75B306298474C09B1D, mem on start (mb), free: 152, total: 414, max: 672
2015-08-12 17:33:35,810 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D7AC068D00FC4E75B306298474C09B1D, mem on close (mb), free: 151, total: 414, max: 672
2015-08-12 17:33:35,835 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown/_temporary
2015-08-12 17:33:35,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.385
2015-08-12 17:33:35,874 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupNoneSortUnknown/none-unknown
2015-08-12 17:33:35,906 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:35,911 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:35,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-08-12 17:33:35,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:35,961 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-08-12 17:33:35,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:35,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 17:33:35,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2015-08-12 17:33:35,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:35,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:35,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:35,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) .../testOOMEPreGroup/oomepre
2015-08-12 17:33:36,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1408196032_0005
2015-08-12 17:33:36,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:36,128 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 17:33:36,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:36,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:36,145 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B92EB8FE65E443E28755AECF6B79F350, ordinal: 0
2015-08-12 17:33:36,146 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 17:33:36,147 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre"]
2015-08-12 17:33:36,147 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B92EB8FE65E443E28755AECF6B79F350, mem on start (mb), free: 91, total: 414, max: 672
2015-08-12 17:33:36,150 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-08-12 17:33:36,157 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B92EB8FE65E443E28755AECF6B79F350, mem on close (mb), free: 91, total: 414, max: 672
2015-08-12 17:33:36,159 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1408196032_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-08-12 17:33:36,164 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] hadoop job job_local1408196032_0005 state at FAILED
2015-08-12 17:33:36,164 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] failure info: NA
2015-08-12 17:33:36,165 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events identify failed tasks
2015-08-12 17:33:36,165 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [test] task completion events count: 0
2015-08-12 17:33:36,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-08-12 17:33:36,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) .../testOOMEPreGroup/oomepre
2015-08-12 17:33:36,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-08-12 17:33:36,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutting down job executor
2015-08-12 17:33:36,171 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] shutdown complete
2015-08-12 17:33:36,171 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre/_temporary
2015-08-12 17:33:36,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.182
exception = cascading.flow.FlowException: local step failed: (1/1) .../testOOMEPreGroup/oomepre
2015-08-12 17:33:36,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testOOMEPreGroup/oomepre
2015-08-12 17:33:36,227 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:36,227 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:36,258 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-08-12 17:33:36,260 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:36,260 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-08-12 17:33:36,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:36,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:36,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy"]
2015-08-12 17:33:36,282 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:36,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:36,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:36,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2015-08-12 17:33:36,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local455054175_0006
2015-08-12 17:33:36,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:36,442 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:36,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:36,450 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:36,456 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A83F7F25FB6645D99DDC13B2F24D368C, ordinal: 0
2015-08-12 17:33:36,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:36,458 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy"]
2015-08-12 17:33:36,459 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A83F7F25FB6645D99DDC13B2F24D368C, mem on start (mb), free: 269, total: 525, max: 672
2015-08-12 17:33:36,462 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A83F7F25FB6645D99DDC13B2F24D368C, mem on close (mb), free: 269, total: 525, max: 672
2015-08-12 17:33:36,488 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testCopy/copy/_temporary
2015-08-12 17:33:36,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.213
2015-08-12 17:33:36,535 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testCopy/copy
2015-08-12 17:33:36,564 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:36,565 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:36,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-08-12 17:33:36,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:36,601 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-08-12 17:33:36,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:36,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2015-08-12 17:33:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:36,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:36,620 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:36,622 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...wnReplace/unknown-replace
2015-08-12 17:33:36,738 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local343962163_0007
2015-08-12 17:33:36,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:36,760 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:36,769 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:36,769 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:36,777 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6C40DC916A94386AEADAA65D3597C5D, ordinal: 0
2015-08-12 17:33:36,778 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:36,778 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace"]
2015-08-12 17:33:36,779 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6C40DC916A94386AEADAA65D3597C5D, mem on start (mb), free: 199, total: 525, max: 672
2015-08-12 17:33:36,781 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6C40DC916A94386AEADAA65D3597C5D, mem on close (mb), free: 199, total: 525, max: 672
2015-08-12 17:33:36,809 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace/_temporary
2015-08-12 17:33:36,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.190
2015-08-12 17:33:36,869 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnknownReplace/unknown-replace
2015-08-12 17:33:36,909 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:36,911 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:36,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-08-12 17:33:36,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:36,961 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-08-12 17:33:36,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:36,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:36,985 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2015-08-12 17:33:36,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:36,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:36,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:36,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...egression/complexlogicand
2015-08-12 17:33:37,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1009893778_0008
2015-08-12 17:33:37,164 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:37,173 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt
2015-08-12 17:33:37,182 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:37,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:37,192 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DD9F5D2566424F5A98580D59804F41BC, ordinal: 0
2015-08-12 17:33:37,193 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:37,193 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand"]
2015-08-12 17:33:37,193 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD9F5D2566424F5A98580D59804F41BC, mem on start (mb), free: 124, total: 525, max: 672
2015-08-12 17:33:37,199 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DD9F5D2566424F5A98580D59804F41BC, mem on close (mb), free: 124, total: 525, max: 672
2015-08-12 17:33:37,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand/_temporary
2015-08-12 17:33:37,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.236
2015-08-12 17:33:37,266 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicAnd/regression/complexlogicand
2015-08-12 17:33:37,323 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:37,325 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:37,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-08-12 17:33:37,368 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:37,368 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-08-12 17:33:37,402 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:37,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:37,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2015-08-12 17:33:37,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:37,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:37,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:37,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...egression/complexlogicxor
2015-08-12 17:33:37,674 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1108285608_0009
2015-08-12 17:33:37,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:37,682 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt
2015-08-12 17:33:37,688 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:37,688 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:37,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BB9D61ECC78A4921B33FDEBE48372FE2, ordinal: 0
2015-08-12 17:33:37,696 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 17:33:37,697 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor"]
2015-08-12 17:33:37,697 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB9D61ECC78A4921B33FDEBE48372FE2, mem on start (mb), free: 289, total: 526, max: 672
2015-08-12 17:33:37,703 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB9D61ECC78A4921B33FDEBE48372FE2, mem on close (mb), free: 289, total: 526, max: 672
2015-08-12 17:33:37,721 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor/_temporary
2015-08-12 17:33:37,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.318
2015-08-12 17:33:37,760 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testComplexLogicXor/regression/complexlogicxor
2015-08-12 17:33:37,804 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:37,805 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:37,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2015-08-12 17:33:37,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:37,867 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-08-12 17:33:37,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 17:33:37,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:33:37,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:37,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2015-08-12 17:33:37,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2015-08-12 17:33:37,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-08-12 17:33:37,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-08-12 17:33:37,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estOOMEPostGroup/oomepost
2015-08-12 17:33:38,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local453767676_0010
2015-08-12 17:33:38,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-12 17:33:38,044 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt
2015-08-12 17:33:38,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:38,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,073 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, ordinal: 0
2015-08-12 17:33:38,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 17:33:38,076 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-12 17:33:38,078 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, mem on start (mb), free: 118, total: 526, max: 672
2015-08-12 17:33:38,081 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, mem on close (mb), free: 118, total: 526, max: 672
2015-08-12 17:33:38,090 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt
2015-08-12 17:33:38,124 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:38,125 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,134 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, ordinal: 0
2015-08-12 17:33:38,136 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:38,137 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-12 17:33:38,137 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, mem on start (mb), free: 211, total: 526, max: 672
2015-08-12 17:33:38,141 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A63A62D0644F45668B3C400ABE686F1C, mem on close (mb), free: 211, total: 526, max: 672
2015-08-12 17:33:38,193 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:38,193 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,205 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CEFE0C103F2640BE974674D43018959F, ordinal: 1
2015-08-12 17:33:38,206 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-08-12 17:33:38,206 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost"]
2015-08-12 17:33:38,206 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEFE0C103F2640BE974674D43018959F, mem on start (mb), free: 204, total: 526, max: 672
2015-08-12 17:33:38,215 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 17:33:38,215 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 17:33:38,216 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-08-12 17:33:38,218 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CEFE0C103F2640BE974674D43018959F, mem on close (mb), free: 203, total: 526, max: 672
2015-08-12 17:33:38,221 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local453767676_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-08-12 17:33:38,227 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] hadoop job job_local453767676_0010 state at FAILED
2015-08-12 17:33:38,227 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] failure info: NA
2015-08-12 17:33:38,227 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events identify failed tasks
2015-08-12 17:33:38,227 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [lower*upper] task completion events count: 0
2015-08-12 17:33:38,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping all jobs
2015-08-12 17:33:38,244 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopping: (1/1) ...estOOMEPostGroup/oomepost
2015-08-12 17:33:38,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] stopped all jobs
2015-08-12 17:33:38,246 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost/_temporary
2015-08-12 17:33:38,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.350
exception = cascading.flow.FlowException: local step failed: (1/1) ...estOOMEPostGroup/oomepost
2015-08-12 17:33:38,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testOOMEPostGroup/oomepost
2015-08-12 17:33:38,309 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:38,313 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:38,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-08-12 17:33:38,372 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:38,372 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-08-12 17:33:38,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:38,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 17:33:38,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2015-08-12 17:33:38,395 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:38,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:38,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:38,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...Modified/lasteachmodified
2015-08-12 17:33:38,545 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local24147258_0011
2015-08-12 17:33:38,546 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:38,553 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt
2015-08-12 17:33:38,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:38,587 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,594 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CB9FEF7A39264A86AA4360B91A5CD95C, ordinal: 0
2015-08-12 17:33:38,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 17:33:38,595 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'insert']]
2015-08-12 17:33:38,596 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB9FEF7A39264A86AA4360B91A5CD95C, mem on start (mb), free: 205, total: 519, max: 672
2015-08-12 17:33:38,599 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB9FEF7A39264A86AA4360B91A5CD95C, mem on close (mb), free: 205, total: 519, max: 672
2015-08-12 17:33:38,626 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:38,627 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,634 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CA3DDFAD92CD493FA150831A34BBED8C, ordinal: 1
2015-08-12 17:33:38,635 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'insert']]
2015-08-12 17:33:38,639 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified"]
2015-08-12 17:33:38,640 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA3DDFAD92CD493FA150831A34BBED8C, mem on start (mb), free: 199, total: 519, max: 672
2015-08-12 17:33:38,651 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CA3DDFAD92CD493FA150831A34BBED8C, mem on close (mb), free: 198, total: 519, max: 672
2015-08-12 17:33:38,671 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified/_temporary
2015-08-12 17:33:38,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.275
2015-08-12 17:33:38,704 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testLastEachNotModified/lasteachmodified
2015-08-12 17:33:38,735 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:38,736 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:38,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-08-12 17:33:38,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:38,764 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-08-12 17:33:38,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:38,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:38,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown"]
2015-08-12 17:33:38,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:38,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:38,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:38,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testUnknown/unknown
2015-08-12 17:33:38,910 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1565449331_0012
2015-08-12 17:33:38,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:38,923 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:38,928 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:38,929 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:38,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E86F2873F1A7497981BF6FF28CE6BB62, ordinal: 0
2015-08-12 17:33:38,937 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:38,938 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown"]
2015-08-12 17:33:38,939 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E86F2873F1A7497981BF6FF28CE6BB62, mem on start (mb), free: 135, total: 519, max: 672
2015-08-12 17:33:38,942 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E86F2873F1A7497981BF6FF28CE6BB62, mem on close (mb), free: 135, total: 519, max: 672
2015-08-12 17:33:38,964 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnknown/unknown/_temporary
2015-08-12 17:33:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.187
2015-08-12 17:33:38,996 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnknown/unknown
2015-08-12 17:33:39,024 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:39,025 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:39,056 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-08-12 17:33:39,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:39,059 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-08-12 17:33:39,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:39,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/critics.txt"]
2015-08-12 17:33:39,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth"]
2015-08-12 17:33:39,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:39,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:39,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:39,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testVarWidth/varwidth
2015-08-12 17:33:39,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local308550174_0013
2015-08-12 17:33:39,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:39,217 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/critics.txt
2015-08-12 17:33:39,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:39,223 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:39,229 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D7E96D7F191B43BFB47E978DABA9ECF0, ordinal: 0
2015-08-12 17:33:39,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/critics.txt"]
2015-08-12 17:33:39,230 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth"]
2015-08-12 17:33:39,230 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7E96D7F191B43BFB47E978DABA9ECF0, mem on start (mb), free: 73, total: 519, max: 672
2015-08-12 17:33:39,232 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D7E96D7F191B43BFB47E978DABA9ECF0, mem on close (mb), free: 73, total: 519, max: 672
2015-08-12 17:33:39,263 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth/_temporary
2015-08-12 17:33:39,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.187
2015-08-12 17:33:39,329 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testVarWidth/varwidth
2015-08-12 17:33:39,373 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:39,374 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:39,380 WARN planner.FlowPlanner (FlowPlanner.java:verifyPipeAssemblyEndPoints(463)) - duplicate head name found, not an error but heads should have unique names: 'test'
2015-08-12 17:33:39,382 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testDupeHeadNames/unknown
2015-08-12 17:33:39,422 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:39,423 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:39,429 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testDupeTailNames/unknown
2015-08-12 17:33:39,956 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:39,957 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:42,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:02.888
2015-08-12 17:33:42,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:42,885 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-08-12 17:33:43,117 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] starting
2015-08-12 17:33:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 17:33:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline"]
2015-08-12 17:33:43,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] parallel execution of steps is enabled: false
2015-08-12 17:33:43,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] executing total steps: 1
2015-08-12 17:33:43,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] allocating management threads: 1
2015-08-12 17:33:43,125 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] starting step: (1/1) ...tDeepPipeline/deeppipline
2015-08-12 17:33:43,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] submitted hadoop job: job_local1519669834_0014
2015-08-12 17:33:43,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] tracking url: http://localhost:8080/
2015-08-12 17:33:43,285 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt
2015-08-12 17:33:43,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:43,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:43,447 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D36AD18D925B4EF9B436C5FAB199E0DE, ordinal: 0
2015-08-12 17:33:43,483 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.200.txt"]
2015-08-12 17:33:43,485 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(pipeline)[by:[{1}:'hash']]
2015-08-12 17:33:43,487 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D36AD18D925B4EF9B436C5FAB199E0DE, mem on start (mb), free: 189, total: 522, max: 672
2015-08-12 17:33:43,784 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D36AD18D925B4EF9B436C5FAB199E0DE, mem on close (mb), free: 177, total: 522, max: 672
2015-08-12 17:33:43,831 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:43,832 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:43,911 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E94A18D0EB4C459DB2D2CEA7514E9C98, ordinal: 1
2015-08-12 17:33:43,934 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(pipeline)[by:[{1}:'hash']]
2015-08-12 17:33:43,935 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline"]
2015-08-12 17:33:43,936 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E94A18D0EB4C459DB2D2CEA7514E9C98, mem on start (mb), free: 169, total: 522, max: 672
2015-08-12 17:33:44,323 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E94A18D0EB4C459DB2D2CEA7514E9C98, mem on close (mb), free: 159, total: 522, max: 672
2015-08-12 17:33:44,351 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline/_temporary
2015-08-12 17:33:44,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [pipeline] completed in: 00:01.234
2015-08-12 17:33:44,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testDeepPipeline/deeppipline
2015-08-12 17:33:44,428 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:44,431 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:44,455 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-08-12 17:33:44,457 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:44,457 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-08-12 17:33:44,471 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting
2015-08-12 17:33:44,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] source: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:44,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] sink: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-08-12 17:33:44,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] parallel execution of steps is enabled: false
2015-08-12 17:33:44,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] executing total steps: 1
2015-08-12 17:33:44,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] allocating management threads: 1
2015-08-12 17:33:44,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] starting step: (1/1) ...litPipe/splitintermediate
2015-08-12 17:33:44,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] submitted hadoop job: job_local202548613_0015
2015-08-12 17:33:44,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] tracking url: http://localhost:8080/
2015-08-12 17:33:44,676 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt
2015-08-12 17:33:44,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:44,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:44,697 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F4B6E673B3384565A8EE7D8B6A9CA051, ordinal: 0
2015-08-12 17:33:44,698 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 17:33:44,699 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-08-12 17:33:44,699 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4B6E673B3384565A8EE7D8B6A9CA051, mem on start (mb), free: 99, total: 522, max: 672
2015-08-12 17:33:44,703 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4B6E673B3384565A8EE7D8B6A9CA051, mem on close (mb), free: 99, total: 522, max: 672
2015-08-12 17:33:44,719 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/_temporary
2015-08-12 17:33:44,722 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [split] completed in: 00:00.247
2015-08-12 17:33:44,762 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:44,762 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:44,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-08-12 17:33:44,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 17:33:44,828 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-08-12 17:33:44,850 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-08-12 17:33:44,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-08-12 17:33:44,851 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2015-08-12 17:33:44,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] parallel execution of steps is enabled: false
2015-08-12 17:33:44,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executing total steps: 1
2015-08-12 17:33:44,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] allocating management threads: 1
2015-08-12 17:33:44,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/1) ...pBySplitPipe/groupbysplit
2015-08-12 17:33:45,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_local428345323_0016
2015-08-12 17:33:45,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:8080/
2015-08-12 17:33:45,023 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate/part-00000
2015-08-12 17:33:45,041 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:45,042 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,048 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A1B38DE00CC64A62A8DCAE2A7DE9BA3C, ordinal: 0
2015-08-12 17:33:45,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate"]
2015-08-12 17:33:45,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-08-12 17:33:45,052 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1B38DE00CC64A62A8DCAE2A7DE9BA3C, mem on start (mb), free: 182, total: 525, max: 672
2015-08-12 17:33:45,056 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A1B38DE00CC64A62A8DCAE2A7DE9BA3C, mem on close (mb), free: 182, total: 525, max: 672
2015-08-12 17:33:45,085 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:45,087 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,093 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D436D4982823404DB07BEBFAB3E6FC1A, ordinal: 1
2015-08-12 17:33:45,100 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(lhs+rhs)[by: lhs:[{1}:'num'] rhs:[{1}:'num']]
2015-08-12 17:33:45,109 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit"]
2015-08-12 17:33:45,111 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D436D4982823404DB07BEBFAB3E6FC1A, mem on start (mb), free: 177, total: 525, max: 672
2015-08-12 17:33:45,136 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D436D4982823404DB07BEBFAB3E6FC1A, mem on close (mb), free: 176, total: 525, max: 672
2015-08-12 17:33:45,175 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit/_temporary
2015-08-12 17:33:45,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] completed in: 00:00.325
2015-08-12 17:33:45,238 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/groupbysplit
2015-08-12 17:33:45,239 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testGroupBySplitPipe/splitintermediate
2015-08-12 17:33:45,263 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:45,266 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:45,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-08-12 17:33:45,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-08-12 17:33:45,321 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-08-12 17:33:45,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting
2015-08-12 17:33:45,347 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:45,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2015-08-12 17:33:45,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] parallel execution of steps is enabled: false
2015-08-12 17:33:45,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] executing total steps: 2
2015-08-12 17:33:45,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] allocating management threads: 1
2015-08-12 17:33:45,354 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting step: (1/2)
2015-08-12 17:33:45,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local2071996967_0017
2015-08-12 17:33:45,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-08-12 17:33:45,521 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:45,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:45,555 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BFD38032C77342579D0089885C5DFB75, ordinal: 0
2015-08-12 17:33:45,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:45,560 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-12 17:33:45,560 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFD38032C77342579D0089885C5DFB75, mem on start (mb), free: 207, total: 525, max: 672
2015-08-12 17:33:45,562 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFD38032C77342579D0089885C5DFB75, mem on close (mb), free: 207, total: 525, max: 672
2015-08-12 17:33:45,580 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:45,580 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,585 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EE1E8FADF6D440CE9CE120E7C9BF741A, ordinal: 1
2015-08-12 17:33:45,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-12 17:33:45,586 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][3749363270/__&%&%bar:bar@foo:_blah_/]
2015-08-12 17:33:45,587 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE1E8FADF6D440CE9CE120E7C9BF741A, mem on start (mb), free: 202, total: 525, max: 672
2015-08-12 17:33:45,605 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EE1E8FADF6D440CE9CE120E7C9BF741A, mem on close (mb), free: 201, total: 525, max: 672
2015-08-12 17:33:45,630 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] starting step: (2/2) ...sInTempFiles/illegalchars
2015-08-12 17:33:45,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] submitted hadoop job: job_local866728068_0018
2015-08-12 17:33:45,772 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] tracking url: http://localhost:8080/
2015-08-12 17:33:45,787 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-root/3749363270____bar_bar_foo__blah__D11D309836544DE69DFC0CCEE98E489E/part-00000
2015-08-12 17:33:45,820 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:45,820 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,825 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D44FD07897224B1B9356339296FDA838, ordinal: 0
2015-08-12 17:33:45,826 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[UNKNOWN]->[ALL]]"][3749363270/__&%&%bar:bar@foo:_blah_/]
2015-08-12 17:33:45,826 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-12 17:33:45,835 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D44FD07897224B1B9356339296FDA838, mem on start (mb), free: 209, total: 526, max: 672
2015-08-12 17:33:45,837 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D44FD07897224B1B9356339296FDA838, mem on close (mb), free: 209, total: 526, max: 672
2015-08-12 17:33:45,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 17:33:45,855 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 17:33:45,859 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C3BA5A0946FB49CC9056D68D4EAEB024, ordinal: 1
2015-08-12 17:33:45,860 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(**&%&%bar:bar@foo://blah/ (*(**^**&%&%^@#@&&() :::: ///\\ illegal chars in it)[by:[{1}:0]]
2015-08-12 17:33:45,861 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars"]
2015-08-12 17:33:45,861 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C3BA5A0946FB49CC9056D68D4EAEB024, mem on start (mb), free: 203, total: 526, max: 672
2015-08-12 17:33:45,867 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C3BA5A0946FB49CC9056D68D4EAEB024, mem on close (mb), free: 202, total: 526, max: 672
2015-08-12 17:33:45,894 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars/_temporary
2015-08-12 17:33:45,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [**&%&%bar:bar@foo://bl...] completed in: 00:00.547
2015-08-12 17:33:45,939 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testIllegalCharsInTempFiles/illegalchars
2015-08-12 17:33:45,965 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 17:33:45,966 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-08-12 17:33:45,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 17:33:45,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 17:33:45,997 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-08-12 17:33:46,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 17:33:46,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:46,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2015-08-12 17:33:46,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 17:33:46,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 17:33:46,021 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 17:33:46,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...-unknown-nondeterministic
2015-08-12 17:33:46,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1472603317_0019
2015-08-12 17:33:46,150 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 17:33:46,168 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt
2015-08-12 17:33:46,175 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 17:33:46,176 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 17:33:46,181 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EEF540B4092C424AA4D1A5B9680A3468, ordinal: 0
2015-08-12 17:33:46,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 17:33:46,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic"]
2015-08-12 17:33:46,186 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEF540B4092C424AA4D1A5B9680A3468, mem on start (mb), free: 142, total: 526, max: 672
2015-08-12 17:33:46,190 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EEF540B4092C424AA4D1A5B9680A3468, mem on close (mb), free: 142, total: 526, max: 672
2015-08-12 17:33:46,205 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic/_temporary
2015-08-12 17:33:46,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.189
2015-08-12 17:33:46,256 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/regressionpipesplatform/testUnGroupUnknown/ungrouped-unknown-nondeterministic