2015-08-12 15:47:10,388 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-08-12 15:47:10,523 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BasicPipesPlatformTest, with platform: hadoop2-mr1
2015-08-12 15:47:10,620 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-08-12 15:47:11,908 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 15:47:12,618 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:12,627 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 15:47:12,902 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5829FCB7F7CF46729CED4C7E6F3BD123
2015-08-12 15:47:13,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.285
2015-08-12 15:47:13,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-08-12 15:47:13,412 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 15:47:13,836 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-08-12 15:47:13,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:13,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:13,855 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/basicpipesplatform/testSimpleChain/simplechain"]
2015-08-12 15:47:13,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:13,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 2
2015-08-12 15:47:13,857 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:13,870 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-08-12 15:47:15,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1238672103_0001
2015-08-12 15:47:15,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:15,335 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 15:47:15,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:15,753 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:15,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6A0796B00784BA3B96DFF0E75BCB98D, ordinal: 0
2015-08-12 15:47:17,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:17,364 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:17,366 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6A0796B00784BA3B96DFF0E75BCB98D, mem on start (mb), free: 298, total: 416, max: 672
2015-08-12 15:47:17,385 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6A0796B00784BA3B96DFF0E75BCB98D, mem on close (mb), free: 296, total: 416, max: 672
2015-08-12 15:47:17,610 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:17,611 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:17,623 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D0DDBAC72C854B78820667361A16FA50, ordinal: 1
2015-08-12 15:47:17,630 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:17,631 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][2461383599/test/]
2015-08-12 15:47:17,641 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D0DDBAC72C854B78820667361A16FA50, mem on start (mb), free: 278, total: 416, max: 672
2015-08-12 15:47:17,689 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D0DDBAC72C854B78820667361A16FA50, mem on close (mb), free: 275, total: 416, max: 672
2015-08-12 15:47:17,754 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...stSimpleChain/simplechain
2015-08-12 15:47:18,238 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local334580074_0002
2015-08-12 15:47:18,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:18,265 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-root/2461383599_test_852863B9ED774510988A04346A47B913/part-00000
2015-08-12 15:47:18,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:18,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:18,408 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E8DA6E1B241F4CE2A5A7E3B2463896C6, ordinal: 0
2015-08-12 15:47:18,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][2461383599/test/]
2015-08-12 15:47:18,409 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:18,410 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8DA6E1B241F4CE2A5A7E3B2463896C6, mem on start (mb), free: 130, total: 416, max: 672
2015-08-12 15:47:18,413 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E8DA6E1B241F4CE2A5A7E3B2463896C6, mem on close (mb), free: 130, total: 416, max: 672
2015-08-12 15:47:18,460 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:18,461 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:18,475 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: CADCBCF170E3460DAF12EA91F741C4A1, ordinal: 1
2015-08-12 15:47:18,476 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:18,477 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/basicpipesplatform/testSimpleChain/simplechain"]
2015-08-12 15:47:18,477 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CADCBCF170E3460DAF12EA91F741C4A1, mem on start (mb), free: 126, total: 416, max: 672
2015-08-12 15:47:18,487 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: CADCBCF170E3460DAF12EA91F741C4A1, mem on close (mb), free: 124, total: 416, max: 672
2015-08-12 15:47:18,566 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain/_temporary
2015-08-12 15:47:18,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:04.710
2015-08-12 15:47:18,683 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleChain/simplechain
2015-08-12 15:47:18,751 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:18,757 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 15:47:18,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.118
2015-08-12 15:47:18,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:18,904 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 15:47:18,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2015-08-12 15:47:18,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:19,000 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count"]
2015-08-12 15:47:19,007 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2015-08-12 15:47:19,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2015-08-12 15:47:19,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2015-08-12 15:47:19,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...splatform/testCount/count
2015-08-12 15:47:20,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local889493417_0003
2015-08-12 15:47:20,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2015-08-12 15:47:20,199 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 15:47:20,237 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:20,237 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:20,247 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D02C978951354433AA25CD15D9656A99, ordinal: 0
2015-08-12 15:47:20,249 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:20,250 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:20,253 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D02C978951354433AA25CD15D9656A99, mem on start (mb), free: 196, total: 325, max: 672
2015-08-12 15:47:20,258 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D02C978951354433AA25CD15D9656A99, mem on close (mb), free: 196, total: 325, max: 672
2015-08-12 15:47:20,287 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:20,288 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:20,300 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E775EF576F8A4520B68B50C3DCCF5F00, ordinal: 1
2015-08-12 15:47:20,301 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:20,302 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count"]
2015-08-12 15:47:20,303 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E775EF576F8A4520B68B50C3DCCF5F00, mem on start (mb), free: 192, total: 325, max: 672
2015-08-12 15:47:20,319 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E775EF576F8A4520B68B50C3DCCF5F00, mem on close (mb), free: 192, total: 325, max: 672
2015-08-12 15:47:20,380 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount/count/_temporary
2015-08-12 15:47:20,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:01.385
2015-08-12 15:47:20,500 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount/count
2015-08-12 15:47:20,540 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:20,542 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 15:47:20,608 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-08-12 15:47:20,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 15:47:20,613 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 15:47:20,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:20,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:20,646 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/basicpipesplatform/testSwap/swap"]
2015-08-12 15:47:20,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:20,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:20,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:20,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2015-08-12 15:47:21,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local56156042_0004
2015-08-12 15:47:21,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:21,020 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 15:47:21,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:21,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:21,108 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9DD088244F44E9EB6385CFCFD2B937A, ordinal: 0
2015-08-12 15:47:21,111 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:21,115 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/basicpipesplatform/testSwap/swap"]
2015-08-12 15:47:21,115 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9DD088244F44E9EB6385CFCFD2B937A, mem on start (mb), free: 290, total: 364, max: 672
2015-08-12 15:47:21,121 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9DD088244F44E9EB6385CFCFD2B937A, mem on close (mb), free: 290, total: 364, max: 672
2015-08-12 15:47:21,184 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSwap/swap/_temporary
2015-08-12 15:47:21,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.539
2015-08-12 15:47:21,367 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSwap/swap
2015-08-12 15:47:21,473 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:21,473 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 15:47:21,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.126
2015-08-12 15:47:21,655 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 15:47:21,657 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 15:47:21,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:21,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 15:47:21,726 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/basicpipesplatform/testUnGroup/ungrouped"]
2015-08-12 15:47:21,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:21,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:21,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:21,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2015-08-12 15:47:22,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1748153128_0005
2015-08-12 15:47:22,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:22,063 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 15:47:22,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:22,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:22,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3A1E597FD3549928EBE999F589DD2BE, ordinal: 0
2015-08-12 15:47:22,102 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 15:47:22,103 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/basicpipesplatform/testUnGroup/ungrouped"]
2015-08-12 15:47:22,104 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3A1E597FD3549928EBE999F589DD2BE, mem on start (mb), free: 316, total: 364, max: 672
2015-08-12 15:47:22,107 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3A1E597FD3549928EBE999F589DD2BE, mem on close (mb), free: 316, total: 364, max: 672
2015-08-12 15:47:22,142 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped/_temporary
2015-08-12 15:47:22,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.417
2015-08-12 15:47:22,179 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testUnGroup/ungrouped
2015-08-12 15:47:22,209 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:22,211 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 15:47:22,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2015-08-12 15:47:22,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:22,314 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 15:47:22,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 15:47:22,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 15:47:22,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 15:47:22,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2015-08-12 15:47:22,366 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2015-08-12 15:47:22,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-08-12 15:47:22,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-08-12 15:47:22,367 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2015-08-12 15:47:22,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1535148124_0006
2015-08-12 15:47:22,531 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-12 15:47:22,538 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 15:47:22,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:22,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:22,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, ordinal: 0
2015-08-12 15:47:22,604 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/upper.txt"]
2015-08-12 15:47:22,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-12 15:47:22,606 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, mem on start (mb), free: 242, total: 364, max: 672
2015-08-12 15:47:22,611 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, mem on close (mb), free: 242, total: 364, max: 672
2015-08-12 15:47:22,643 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 15:47:22,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:22,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:22,705 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, ordinal: 0
2015-08-12 15:47:22,706 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.txt"]
2015-08-12 15:47:22,706 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-12 15:47:22,706 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, mem on start (mb), free: 242, total: 464, max: 672
2015-08-12 15:47:22,708 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B916035DAD2D4D4C871DD5FF81CB5675, mem on close (mb), free: 242, total: 464, max: 672
2015-08-12 15:47:22,731 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:22,733 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:22,742 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B140851B3F3F45C6A23EC345FF7F2FA2, ordinal: 1
2015-08-12 15:47:22,743 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-12 15:47:22,744 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown"]
2015-08-12 15:47:22,744 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B140851B3F3F45C6A23EC345FF7F2FA2, mem on start (mb), free: 239, total: 464, max: 672
2015-08-12 15:47:22,759 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 15:47:22,760 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 15:47:22,769 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B140851B3F3F45C6A23EC345FF7F2FA2, mem on close (mb), free: 236, total: 464, max: 672
2015-08-12 15:47:22,812 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown/_temporary
2015-08-12 15:47:22,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.446
2015-08-12 15:47:22,900 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCoGroupRelativeUnknown/complexcogrouprelativeunknown
2015-08-12 15:47:22,971 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:22,972 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 15:47:23,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2015-08-12 15:47:23,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:23,028 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 15:47:23,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:23,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:23,082 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/basicpipesplatform/testSimpleRelative/simplerelative"]
2015-08-12 15:47:23,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:23,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:23,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:23,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...leRelative/simplerelative
2015-08-12 15:47:23,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1107420674_0007
2015-08-12 15:47:23,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:23,245 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 15:47:25,502 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:25,503 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:25,514 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B9352CFBB2A7497F8ADC82F2E3AD8E25, ordinal: 0
2015-08-12 15:47:25,516 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:25,517 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:25,519 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9352CFBB2A7497F8ADC82F2E3AD8E25, mem on start (mb), free: 176, total: 565, max: 672
2015-08-12 15:47:25,521 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9352CFBB2A7497F8ADC82F2E3AD8E25, mem on close (mb), free: 176, total: 565, max: 672
2015-08-12 15:47:25,540 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:25,542 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:25,563 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C3008B985B684CDCB4C5CFB02BAEE341, ordinal: 1
2015-08-12 15:47:25,564 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:25,564 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/basicpipesplatform/testSimpleRelative/simplerelative"]
2015-08-12 15:47:25,565 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C3008B985B684CDCB4C5CFB02BAEE341, mem on start (mb), free: 173, total: 565, max: 672
2015-08-12 15:47:25,580 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C3008B985B684CDCB4C5CFB02BAEE341, mem on close (mb), free: 172, total: 565, max: 672
2015-08-12 15:47:25,614 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative/_temporary
2015-08-12 15:47:25,615 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:02.541
2015-08-12 15:47:25,827 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleRelative/simplerelative
2015-08-12 15:47:26,236 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:26,238 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 15:47:26,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2015-08-12 15:47:26,330 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:26,330 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 15:47:26,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:26,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 15:47:26,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult"]
2015-08-12 15:47:26,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:26,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:26,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:26,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleResult/simpleresult
2015-08-12 15:47:26,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local2068643233_0008
2015-08-12 15:47:26,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:26,586 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 15:47:26,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:26,606 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:26,615 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BB5E0DE2438741ABBA675DE1B7A8802E, ordinal: 0
2015-08-12 15:47:26,618 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 15:47:26,620 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:26,621 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB5E0DE2438741ABBA675DE1B7A8802E, mem on start (mb), free: 176, total: 348, max: 672
2015-08-12 15:47:26,727 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BB5E0DE2438741ABBA675DE1B7A8802E, mem on close (mb), free: 169, total: 348, max: 672
2015-08-12 15:47:26,748 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:26,750 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:26,758 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FFFE8690217846908D19EA3845F16CBC, ordinal: 1
2015-08-12 15:47:26,760 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:26,761 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult"]
2015-08-12 15:47:26,762 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FFFE8690217846908D19EA3845F16CBC, mem on start (mb), free: 165, total: 348, max: 672
2015-08-12 15:47:26,779 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FFFE8690217846908D19EA3845F16CBC, mem on close (mb), free: 165, total: 348, max: 672
2015-08-12 15:47:26,833 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult/_temporary
2015-08-12 15:47:26,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.436
2015-08-12 15:47:26,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleResult/simpleresult
2015-08-12 15:47:27,019 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:27,020 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 15:47:27,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.117
2015-08-12 15:47:27,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 15:47:27,152 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 15:47:27,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:27,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:27,178 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/basicpipesplatform/testFilterAll/filterall"]
2015-08-12 15:47:27,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:27,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:27,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:27,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2015-08-12 15:47:27,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1141672147_0009
2015-08-12 15:47:27,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:27,391 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 15:47:27,405 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:27,406 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:27,414 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB9B3BDF08AF49258974CCD451D9668F, ordinal: 0
2015-08-12 15:47:27,414 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:27,414 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/basicpipesplatform/testFilterAll/filterall"]
2015-08-12 15:47:27,415 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB9B3BDF08AF49258974CCD451D9668F, mem on start (mb), free: 309, total: 364, max: 672
2015-08-12 15:47:27,416 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB9B3BDF08AF49258974CCD451D9668F, mem on close (mb), free: 309, total: 364, max: 672
2015-08-12 15:47:27,439 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilterAll/filterall/_temporary
2015-08-12 15:47:27,440 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.262
2015-08-12 15:47:27,498 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testFilterAll/filterall
2015-08-12 15:47:27,534 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:27,535 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 15:47:27,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2015-08-12 15:47:27,627 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:27,627 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 15:47:27,653 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:27,655 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.txt"]
2015-08-12 15:47:27,655 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/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2015-08-12 15:47:27,656 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:27,656 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:27,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:27,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...own/simplerelativeunknown
2015-08-12 15:47:27,947 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1243507876_0010
2015-08-12 15:47:27,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:27,965 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 15:47:28,032 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:28,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:28,051 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6738718020D4CD39438404234839808, ordinal: 0
2015-08-12 15:47:28,053 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.txt"]
2015-08-12 15:47:28,054 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2015-08-12 15:47:28,054 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6738718020D4CD39438404234839808, mem on start (mb), free: 235, total: 364, max: 672
2015-08-12 15:47:28,090 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6738718020D4CD39438404234839808, mem on close (mb), free: 235, total: 364, max: 672
2015-08-12 15:47:28,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:28,153 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:28,164 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A3E1776EA83D4538BE469030C2A1D8C9, ordinal: 1
2015-08-12 15:47:28,166 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2015-08-12 15:47:28,167 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/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown"]
2015-08-12 15:47:28,167 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A3E1776EA83D4538BE469030C2A1D8C9, mem on start (mb), free: 232, total: 364, max: 672
2015-08-12 15:47:28,187 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A3E1776EA83D4538BE469030C2A1D8C9, mem on close (mb), free: 231, total: 364, max: 672
2015-08-12 15:47:28,232 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown/_temporary
2015-08-12 15:47:28,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.578
2015-08-12 15:47:28,312 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimpleRelativeUnknown/simplerelativeunknown
2015-08-12 15:47:28,371 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:28,373 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 15:47:28,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.136
2015-08-12 15:47:28,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:28,529 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 15:47:28,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-08-12 15:47:28,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 15:47:28,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 15:47:28,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup"]
2015-08-12 15:47:28,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2015-08-12 15:47:28,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-08-12 15:47:28,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-08-12 15:47:28,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...estCoGroup/complexcogroup
2015-08-12 15:47:28,846 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local529192578_0011
2015-08-12 15:47:28,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-12 15:47:28,859 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 15:47:28,916 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:28,916 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:28,927 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED89A5CA42104094A5C03177DB87208A, ordinal: 0
2015-08-12 15:47:28,929 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 15:47:28,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-12 15:47:28,930 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED89A5CA42104094A5C03177DB87208A, mem on start (mb), free: 175, total: 465, max: 672
2015-08-12 15:47:28,934 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED89A5CA42104094A5C03177DB87208A, mem on close (mb), free: 175, total: 465, max: 672
2015-08-12 15:47:28,966 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 15:47:29,007 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:29,007 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:29,016 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED89A5CA42104094A5C03177DB87208A, ordinal: 0
2015-08-12 15:47:29,017 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 15:47:29,017 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-12 15:47:29,018 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED89A5CA42104094A5C03177DB87208A, mem on start (mb), free: 174, total: 565, max: 672
2015-08-12 15:47:29,019 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED89A5CA42104094A5C03177DB87208A, mem on close (mb), free: 174, total: 565, max: 672
2015-08-12 15:47:29,100 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:29,100 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:29,116 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C0EECC64477746D2A683EB0CD23819B2, ordinal: 1
2015-08-12 15:47:29,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-12 15:47:29,117 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup"]
2015-08-12 15:47:29,117 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0EECC64477746D2A683EB0CD23819B2, mem on start (mb), free: 171, total: 565, max: 672
2015-08-12 15:47:29,159 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 15:47:29,159 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-12 15:47:29,162 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0EECC64477746D2A683EB0CD23819B2, mem on close (mb), free: 171, total: 565, max: 672
2015-08-12 15:47:29,505 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup/_temporary
2015-08-12 15:47:29,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.920
2015-08-12 15:47:29,848 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCoGroup/complexcogroup
2015-08-12 15:47:29,885 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:29,886 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 15:47:29,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-08-12 15:47:29,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 15:47:29,939 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 15:47:29,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:29,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:29,971 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/basicpipesplatform/testReplace/replace"]
2015-08-12 15:47:29,972 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:29,977 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:29,977 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:30,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2015-08-12 15:47:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local750443113_0012
2015-08-12 15:47:30,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:30,207 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 15:47:30,212 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:30,213 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:30,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B4CEA6D486DC4C028270439E89C93DA9, ordinal: 0
2015-08-12 15:47:30,224 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:30,225 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/basicpipesplatform/testReplace/replace"]
2015-08-12 15:47:30,226 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4CEA6D486DC4C028270439E89C93DA9, mem on start (mb), free: 298, total: 368, max: 672
2015-08-12 15:47:30,229 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B4CEA6D486DC4C028270439E89C93DA9, mem on close (mb), free: 298, total: 368, max: 672
2015-08-12 15:47:30,252 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testReplace/replace/_temporary
2015-08-12 15:47:30,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.283
2015-08-12 15:47:30,331 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testReplace/replace
2015-08-12 15:47:30,368 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:30,370 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 15:47:30,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-08-12 15:47:30,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:30,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 15:47:30,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2015-08-12 15:47:30,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:30,449 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2"]
2015-08-12 15:47:30,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2015-08-12 15:47:30,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2015-08-12 15:47:30,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2015-08-12 15:47:30,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount2/count2
2015-08-12 15:47:30,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local639438385_0013
2015-08-12 15:47:30,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2015-08-12 15:47:30,649 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 15:47:30,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:30,669 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:30,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5F4E9BBD3524B268A17DD921CB35E81, ordinal: 0
2015-08-12 15:47:30,678 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:30,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:30,680 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5F4E9BBD3524B268A17DD921CB35E81, mem on start (mb), free: 227, total: 368, max: 672
2015-08-12 15:47:30,684 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5F4E9BBD3524B268A17DD921CB35E81, mem on close (mb), free: 227, total: 368, max: 672
2015-08-12 15:47:30,710 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:30,710 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:30,719 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F0BDF4BCE0E64F90B5796C21CD8CF712, ordinal: 1
2015-08-12 15:47:30,723 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:30,724 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2"]
2015-08-12 15:47:30,724 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0BDF4BCE0E64F90B5796C21CD8CF712, mem on start (mb), free: 224, total: 368, max: 672
2015-08-12 15:47:30,737 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0BDF4BCE0E64F90B5796C21CD8CF712, mem on close (mb), free: 224, total: 368, max: 672
2015-08-12 15:47:30,816 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount2/count2/_temporary
2015-08-12 15:47:30,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.369
2015-08-12 15:47:30,978 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount2/count2
2015-08-12 15:47:31,011 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:31,014 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 15:47:31,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-08-12 15:47:31,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:31,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 15:47:31,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2015-08-12 15:47:31,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:31,084 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3"]
2015-08-12 15:47:31,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2015-08-12 15:47:31,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2015-08-12 15:47:31,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2015-08-12 15:47:31,092 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount3/count3
2015-08-12 15:47:31,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local642940561_0014
2015-08-12 15:47:31,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2015-08-12 15:47:31,350 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 15:47:31,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:31,370 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:31,377 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C57FE2241F4F41859D91FEDCBB63D37E, ordinal: 0
2015-08-12 15:47:31,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:31,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:31,379 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C57FE2241F4F41859D91FEDCBB63D37E, mem on start (mb), free: 259, total: 376, max: 672
2015-08-12 15:47:31,392 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C57FE2241F4F41859D91FEDCBB63D37E, mem on close (mb), free: 259, total: 376, max: 672
2015-08-12 15:47:31,413 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:31,414 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:31,425 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F0F69E04B6F144B5A7DFF8154ED66D8F, ordinal: 1
2015-08-12 15:47:31,427 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:31,429 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3"]
2015-08-12 15:47:31,433 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0F69E04B6F144B5A7DFF8154ED66D8F, mem on start (mb), free: 256, total: 376, max: 672
2015-08-12 15:47:31,445 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F0F69E04B6F144B5A7DFF8154ED66D8F, mem on close (mb), free: 256, total: 376, max: 672
2015-08-12 15:47:31,480 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount3/count3/_temporary
2015-08-12 15:47:31,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.399
2015-08-12 15:47:31,587 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount3/count3
2015-08-12 15:47:31,649 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:31,657 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 15:47:31,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-08-12 15:47:31,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:31,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-08-12 15:47:31,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting
2015-08-12 15:47:31,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:31,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4"]
2015-08-12 15:47:31,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] parallel execution of steps is enabled: false
2015-08-12 15:47:31,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] executing total steps: 1
2015-08-12 15:47:31,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] allocating management threads: 1
2015-08-12 15:47:31,753 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] starting step: (1/1) ...latform/testCount4/count4
2015-08-12 15:47:31,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] submitted hadoop job: job_local1473831745_0015
2015-08-12 15:47:31,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] tracking url: http://localhost:8080/
2015-08-12 15:47:31,918 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt
2015-08-12 15:47:31,981 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:31,982 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:31,990 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D947F19B896442E4A783E2735D1FFB76, ordinal: 0
2015-08-12 15:47:31,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/ips.20.txt"]
2015-08-12 15:47:31,991 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:31,996 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D947F19B896442E4A783E2735D1FFB76, mem on start (mb), free: 197, total: 477, max: 672
2015-08-12 15:47:32,002 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D947F19B896442E4A783E2735D1FFB76, mem on close (mb), free: 197, total: 477, max: 672
2015-08-12 15:47:32,063 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:32,064 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:32,073 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A804A18E0D73411B9D3CA727AFBD8986, ordinal: 1
2015-08-12 15:47:32,074 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-12 15:47:32,074 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4"]
2015-08-12 15:47:32,074 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A804A18E0D73411B9D3CA727AFBD8986, mem on start (mb), free: 194, total: 477, max: 672
2015-08-12 15:47:32,113 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A804A18E0D73411B9D3CA727AFBD8986, mem on close (mb), free: 193, total: 477, max: 672
2015-08-12 15:47:32,159 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testCount4/count4/_temporary
2015-08-12 15:47:32,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [count] completed in: 00:00.415
2015-08-12 15:47:32,260 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testCount4/count4
2015-08-12 15:47:32,293 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:32,294 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 15:47:32,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-08-12 15:47:32,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-08-12 15:47:32,324 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 15:47:32,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:32,373 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:32,375 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/basicpipesplatform/testFilter/filter"]
2015-08-12 15:47:32,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:32,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:32,380 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:32,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2015-08-12 15:47:32,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local762222537_0016
2015-08-12 15:47:32,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:32,535 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 15:47:32,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:32,544 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:32,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C211EF66F9A8437BB104FFE00EE17BA1, ordinal: 0
2015-08-12 15:47:32,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:32,549 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/basicpipesplatform/testFilter/filter"]
2015-08-12 15:47:32,549 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C211EF66F9A8437BB104FFE00EE17BA1, mem on start (mb), free: 215, total: 477, max: 672
2015-08-12 15:47:32,551 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C211EF66F9A8437BB104FFE00EE17BA1, mem on close (mb), free: 215, total: 477, max: 672
2015-08-12 15:47:32,562 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testFilter/filter/_temporary
2015-08-12 15:47:32,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.191
2015-08-12 15:47:32,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testFilter/filter
2015-08-12 15:47:32,632 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 15:47:32,633 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 15:47:32,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-08-12 15:47:32,673 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-08-12 15:47:32,673 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 15:47:32,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-08-12 15:47:32,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:32,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple"]
2015-08-12 15:47:32,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-08-12 15:47:32,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-08-12 15:47:32,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-08-12 15:47:32,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testSimple/simple
2015-08-12 15:47:32,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local520695560_0017
2015-08-12 15:47:32,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-08-12 15:47:32,879 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 15:47:32,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-08-12 15:47:32,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-08-12 15:47:32,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3EC7750C1D5429E9A9553DC45FBB5D6, ordinal: 0
2015-08-12 15:47:32,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/apache.10.txt"]
2015-08-12 15:47:32,931 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:32,931 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3EC7750C1D5429E9A9553DC45FBB5D6, mem on start (mb), free: 247, total: 577, max: 672
2015-08-12 15:47:32,933 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3EC7750C1D5429E9A9553DC45FBB5D6, mem on close (mb), free: 247, total: 577, max: 672
2015-08-12 15:47:32,960 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-08-12 15:47:32,962 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-08-12 15:47:32,970 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AA90856605F94D7C81DA77C93CBC1B9F, ordinal: 1
2015-08-12 15:47:32,972 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-12 15:47:32,973 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple"]
2015-08-12 15:47:32,973 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA90856605F94D7C81DA77C93CBC1B9F, mem on start (mb), free: 244, total: 577, max: 672
2015-08-12 15:47:32,981 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AA90856605F94D7C81DA77C93CBC1B9F, mem on close (mb), free: 243, total: 577, max: 672
2015-08-12 15:47:33,017 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/basicpipesplatform/testSimple/simple/_temporary
2015-08-12 15:47:33,022 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.317
2015-08-12 15:47:33,076 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /home/cascading/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/basicpipesplatform/testSimple/simple