2015-11-23 15:22:32,299 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-11-23 15:22:32,314 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BufferPipesPlatformTest, with platform: hadoop2-mr1
2015-11-23 15:22:32,327 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-11-23 15:22:32,721 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-11-23 15:22:32,798 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-11-23 15:22:32,853 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:32,855 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-11-23 15:22:32,902 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: B6B1BE49611045BDBB8576E5BE4C72B3
2015-11-23 15:22:32,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-11-23 15:22:32,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:32,994 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-11-23 15:22:33,134 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-11-23 15:22:33,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:33,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:33,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2015-11-23 15:22:33,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:33,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:33,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:33,138 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stIdentityBuffer/identity
2015-11-23 15:22:33,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local32158405_0001
2015-11-23 15:22:33,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:33,534 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:33,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:33,577 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:33,586 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0812336EFA243F386A8722CEC3B28F7, ordinal: 0
2015-11-23 15:22:33,612 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:33,613 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:33,613 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0812336EFA243F386A8722CEC3B28F7, mem on start (mb), free: 218, total: 337, max: 672
2015-11-23 15:22:33,621 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0812336EFA243F386A8722CEC3B28F7, mem on close (mb), free: 217, total: 337, max: 672
2015-11-23 15:22:33,691 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:33,691 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:33,698 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E32FB9647D33455CB17EE8ED6B08E0C3, ordinal: 1
2015-11-23 15:22:33,700 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:33,700 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2015-11-23 15:22:33,700 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E32FB9647D33455CB17EE8ED6B08E0C3, mem on start (mb), free: 207, total: 337, max: 672
2015-11-23 15:22:33,720 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E32FB9647D33455CB17EE8ED6B08E0C3, mem on close (mb), free: 205, total: 337, max: 672
2015-11-23 15:22:33,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity/_temporary
2015-11-23 15:22:33,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.623
2015-11-23 15:22:33,813 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity
2015-11-23 15:22:33,839 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:33,840 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-11-23 15:22:33,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-11-23 15:22:33,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:33,873 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-11-23 15:22:33,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:33,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:33,898 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2015-11-23 15:22:33,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:33,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:33,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:33,899 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferForward/firstn
2015-11-23 15:22:34,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1799545505_0002
2015-11-23 15:22:34,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:34,057 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:34,099 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:34,100 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,105 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C09F2BEC97CE470ABA3C037E0A795F70, ordinal: 0
2015-11-23 15:22:34,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:34,106 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:34,106 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C09F2BEC97CE470ABA3C037E0A795F70, mem on start (mb), free: 165, total: 337, max: 672
2015-11-23 15:22:34,108 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C09F2BEC97CE470ABA3C037E0A795F70, mem on close (mb), free: 165, total: 337, max: 672
2015-11-23 15:22:34,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:34,118 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,124 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B05D06CCEAC54290852D15269B0F1FCF, ordinal: 1
2015-11-23 15:22:34,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:34,125 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2015-11-23 15:22:34,125 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B05D06CCEAC54290852D15269B0F1FCF, mem on start (mb), free: 161, total: 337, max: 672
2015-11-23 15:22:34,132 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B05D06CCEAC54290852D15269B0F1FCF, mem on close (mb), free: 160, total: 337, max: 672
2015-11-23 15:22:34,148 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn/_temporary
2015-11-23 15:22:34,149 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.250
2015-11-23 15:22:34,190 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn
2015-11-23 15:22:34,209 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:34,209 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-11-23 15:22:34,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-11-23 15:22:34,238 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:34,238 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-11-23 15:22:34,252 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:34,252 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:34,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2015-11-23 15:22:34,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:34,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:34,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:34,253 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testSimpleBuffer/simple
2015-11-23 15:22:34,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local325228250_0003
2015-11-23 15:22:34,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:34,353 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:34,378 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:34,379 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D4C8D439055A47B184DF16BEDCDB192B, ordinal: 0
2015-11-23 15:22:34,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:34,383 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:34,384 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4C8D439055A47B184DF16BEDCDB192B, mem on start (mb), free: 178, total: 393, max: 672
2015-11-23 15:22:34,385 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D4C8D439055A47B184DF16BEDCDB192B, mem on close (mb), free: 178, total: 393, max: 672
2015-11-23 15:22:34,396 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:34,397 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,401 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AE5EEBE08F4E45B3801B659FDDE90F2D, ordinal: 1
2015-11-23 15:22:34,402 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:34,402 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2015-11-23 15:22:34,402 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AE5EEBE08F4E45B3801B659FDDE90F2D, mem on start (mb), free: 173, total: 393, max: 672
2015-11-23 15:22:34,409 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AE5EEBE08F4E45B3801B659FDDE90F2D, mem on close (mb), free: 171, total: 393, max: 672
2015-11-23 15:22:34,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple/_temporary
2015-11-23 15:22:34,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.171
2015-11-23 15:22:34,464 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple
2015-11-23 15:22:34,480 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:34,480 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-11-23 15:22:34,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-11-23 15:22:34,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:34,511 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-11-23 15:22:34,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower.txt"]
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/upper.txt"]
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-11-23 15:22:34,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-11-23 15:22:34,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...testJoinerClosure/cogroup
2015-11-23 15:22:34,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local596612907_0004
2015-11-23 15:22:34,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2015-11-23 15:22:34,630 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower.txt
2015-11-23 15:22:34,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:34,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,678 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, ordinal: 0
2015-11-23 15:22:34,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower.txt"]
2015-11-23 15:22:34,679 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-11-23 15:22:34,680 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, mem on start (mb), free: 107, total: 494, max: 672
2015-11-23 15:22:34,681 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, mem on close (mb), free: 107, total: 494, max: 672
2015-11-23 15:22:34,688 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/upper.txt
2015-11-23 15:22:34,732 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:34,733 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, ordinal: 0
2015-11-23 15:22:34,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/upper.txt"]
2015-11-23 15:22:34,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-11-23 15:22:34,737 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, mem on start (mb), free: 106, total: 594, max: 672
2015-11-23 15:22:34,739 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAC711EAE2B2490E9A49651389E8F43E, mem on close (mb), free: 106, total: 594, max: 672
2015-11-23 15:22:34,750 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:34,750 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,753 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A4DC30A033B445158CDC59C865AAC4ED, ordinal: 1
2015-11-23 15:22:34,754 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2015-11-23 15:22:34,754 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2015-11-23 15:22:34,754 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DC30A033B445158CDC59C865AAC4ED, mem on start (mb), free: 102, total: 594, max: 672
2015-11-23 15:22:34,764 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-11-23 15:22:34,764 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-11-23 15:22:34,769 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4DC30A033B445158CDC59C865AAC4ED, mem on close (mb), free: 100, total: 594, max: 672
2015-11-23 15:22:34,793 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup/_temporary
2015-11-23 15:22:34,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.266
2015-11-23 15:22:34,835 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup
2015-11-23 15:22:34,851 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:34,851 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-11-23 15:22:34,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2015-11-23 15:22:34,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:34,873 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-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2015-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:34,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:34,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer2/simple2
2015-11-23 15:22:34,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1868891387_0005
2015-11-23 15:22:34,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:34,978 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:34,996 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:34,996 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:34,999 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF2975001773452492ECFD2496F2493E, ordinal: 0
2015-11-23 15:22:35,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:35,000 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,000 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF2975001773452492ECFD2496F2493E, mem on start (mb), free: 128, total: 599, max: 672
2015-11-23 15:22:35,001 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF2975001773452492ECFD2496F2493E, mem on close (mb), free: 128, total: 599, max: 672
2015-11-23 15:22:35,010 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:35,010 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,013 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A8A68DA4F842400A8A7229CC6812E252, ordinal: 1
2015-11-23 15:22:35,013 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,013 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2015-11-23 15:22:35,013 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8A68DA4F842400A8A7229CC6812E252, mem on start (mb), free: 124, total: 599, max: 672
2015-11-23 15:22:35,021 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A8A68DA4F842400A8A7229CC6812E252, mem on close (mb), free: 122, total: 599, max: 672
2015-11-23 15:22:35,039 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2/_temporary
2015-11-23 15:22:35,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.156
2015-11-23 15:22:35,090 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2
2015-11-23 15:22:35,107 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:35,108 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-11-23 15:22:35,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-11-23 15:22:35,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:35,137 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-11-23 15:22:35,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:35,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower+upper.txt"]
2015-11-23 15:22:35,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2015-11-23 15:22:35,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:35,154 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:35,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:35,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer3/simple3
2015-11-23 15:22:35,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local999997548_0006
2015-11-23 15:22:35,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:35,246 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower+upper.txt
2015-11-23 15:22:35,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:35,269 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,272 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF1681CE24AD4BDBAE2C1C583C68D0D3, ordinal: 0
2015-11-23 15:22:35,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lower+upper.txt"]
2015-11-23 15:22:35,273 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,273 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF1681CE24AD4BDBAE2C1C583C68D0D3, mem on start (mb), free: 167, total: 622, max: 672
2015-11-23 15:22:35,274 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF1681CE24AD4BDBAE2C1C583C68D0D3, mem on close (mb), free: 167, total: 622, max: 672
2015-11-23 15:22:35,284 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:35,284 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,289 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A55F52E4605349C6A6D43C1A7496A61E, ordinal: 1
2015-11-23 15:22:35,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,290 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2015-11-23 15:22:35,290 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A55F52E4605349C6A6D43C1A7496A61E, mem on start (mb), free: 161, total: 622, max: 672
2015-11-23 15:22:35,298 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A55F52E4605349C6A6D43C1A7496A61E, mem on close (mb), free: 159, total: 622, max: 672
2015-11-23 15:22:35,317 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3/_temporary
2015-11-23 15:22:35,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.164
2015-11-23 15:22:35,359 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3
2015-11-23 15:22:35,374 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:35,375 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-11-23 15:22:35,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-11-23 15:22:35,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:35,392 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-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2015-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:35,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:35,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferReverse/firstn
2015-11-23 15:22:35,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1429479457_0007
2015-11-23 15:22:35,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:35,513 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:35,532 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:35,533 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,535 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C99A7BE2D88E47739F5FDE18A91A4A1D, ordinal: 0
2015-11-23 15:22:35,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:35,536 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,536 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C99A7BE2D88E47739F5FDE18A91A4A1D, mem on start (mb), free: 208, total: 623, max: 672
2015-11-23 15:22:35,537 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C99A7BE2D88E47739F5FDE18A91A4A1D, mem on close (mb), free: 207, total: 623, max: 672
2015-11-23 15:22:35,544 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:35,545 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,547 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D393BCC19DAE4851936C94211B9063E4, ordinal: 1
2015-11-23 15:22:35,548 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,548 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2015-11-23 15:22:35,548 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D393BCC19DAE4851936C94211B9063E4, mem on start (mb), free: 203, total: 623, max: 672
2015-11-23 15:22:35,554 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D393BCC19DAE4851936C94211B9063E4, mem on close (mb), free: 201, total: 623, max: 672
2015-11-23 15:22:35,574 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn/_temporary
2015-11-23 15:22:35,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.170
2015-11-23 15:22:35,625 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn
2015-11-23 15:22:35,642 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:35,642 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-11-23 15:22:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.005
2015-11-23 15:22:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-11-23 15:22:35,668 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-11-23 15:22:35,669 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-11-23 15:22:35,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-11-23 15:22:35,685 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-11-23 15:22:35,685 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-11-23 15:22:35,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-11-23 15:22:35,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:35,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2015-11-23 15:22:35,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2015-11-23 15:22:35,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-11-23 15:22:35,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-11-23 15:22:35,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFirstNBuffer/firstn
2015-11-23 15:22:35,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1612560391_0008
2015-11-23 15:22:35,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2015-11-23 15:22:35,789 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt
2015-11-23 15:22:35,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-11-23 15:22:35,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED59362B7BB1423D9D33F13D264FBDD2, ordinal: 0
2015-11-23 15:22:35,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/classes/test/data/lhs.txt"]
2015-11-23 15:22:35,818 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,818 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED59362B7BB1423D9D33F13D264FBDD2, mem on start (mb), free: 214, total: 628, max: 672
2015-11-23 15:22:35,819 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED59362B7BB1423D9D33F13D264FBDD2, mem on close (mb), free: 214, total: 628, max: 672
2015-11-23 15:22:35,826 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.2
2015-11-23 15:22:35,827 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2015-11-23 15:22:35,829 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9AA1C87FB414C2EBADFDEFDA99941B3, ordinal: 1
2015-11-23 15:22:35,830 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2015-11-23 15:22:35,830 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2015-11-23 15:22:35,830 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9AA1C87FB414C2EBADFDEFDA99941B3, mem on start (mb), free: 210, total: 628, max: 672
2015-11-23 15:22:35,836 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9AA1C87FB414C2EBADFDEFDA99941B3, mem on close (mb), free: 207, total: 628, max: 672
2015-11-23 15:22:35,852 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn/_temporary
2015-11-23 15:22:35,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.157
2015-11-23 15:22:35,899 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /root/yuanbo/cascading.compatibility-3.0/biginsights-4.1/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn