2016-01-15 01:43:39,088 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 01:43:39,121 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BufferPipesPlatformTest, with platform: hadoop2-mr1
2016-01-15 01:43:39,159 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-15 01:43:39,943 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-15 01:43:40,117 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-15 01:43:40,281 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:40,284 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:40,406 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 76372FAC1D0A401F9CFDD6F22FA29FB8
2016-01-15 01:43:40,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.116
2016-01-15 01:43:40,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:40,577 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'
2016-01-15 01:43:40,721 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 01:43:40,724 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:40,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:40,726 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-15 01:43:40,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:40,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:40,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:40,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stIdentityBuffer/identity
2016-01-15 01:43:41,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local893317139_0001
2016-01-15 01:43:41,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:41,456 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:41,596 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:41,596 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:41,607 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EB3048DE9DFE4F1FB207F7F68DBED890, ordinal: 0
2016-01-15 01:43:41,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:41,651 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:41,652 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB3048DE9DFE4F1FB207F7F68DBED890, mem on start (mb), free: 68, total: 223, max: 672
2016-01-15 01:43:41,661 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EB3048DE9DFE4F1FB207F7F68DBED890, mem on close (mb), free: 68, total: 223, max: 672
2016-01-15 01:43:41,773 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:41,773 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:41,784 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D5A842C72950484994CE9670267EA2AF, ordinal: 1
2016-01-15 01:43:41,788 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:41,788 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-15 01:43:41,788 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5A842C72950484994CE9670267EA2AF, mem on start (mb), free: 55, total: 223, max: 672
2016-01-15 01:43:41,810 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D5A842C72950484994CE9670267EA2AF, mem on close (mb), free: 54, total: 223, max: 672
2016-01-15 01:43:41,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity/_temporary
2016-01-15 01:43:41,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:01.135
2016-01-15 01:43:41,931 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity
2016-01-15 01:43:41,957 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:41,958 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:42,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-01-15 01:43:42,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:42,030 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'
2016-01-15 01:43:42,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:42,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:42,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-15 01:43:42,061 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:42,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:42,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:42,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferForward/firstn
2016-01-15 01:43:42,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local2094439697_0002
2016-01-15 01:43:42,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:42,226 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:42,336 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:42,337 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:42,348 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FB3C2D61302F498394156BBDFFA697C0, ordinal: 0
2016-01-15 01:43:42,349 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:42,349 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:42,349 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB3C2D61302F498394156BBDFFA697C0, mem on start (mb), free: 59, total: 323, max: 672
2016-01-15 01:43:42,354 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FB3C2D61302F498394156BBDFFA697C0, mem on close (mb), free: 58, total: 323, max: 672
2016-01-15 01:43:42,373 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:42,373 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:42,388 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A7EFD59B8FD4476FA0DF2087B1199991, ordinal: 1
2016-01-15 01:43:42,388 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:42,389 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-15 01:43:42,389 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A7EFD59B8FD4476FA0DF2087B1199991, mem on start (mb), free: 56, total: 323, max: 672
2016-01-15 01:43:42,399 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A7EFD59B8FD4476FA0DF2087B1199991, mem on close (mb), free: 55, total: 323, max: 672
2016-01-15 01:43:42,441 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn/_temporary
2016-01-15 01:43:42,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.380
2016-01-15 01:43:42,523 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn
2016-01-15 01:43:42,557 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:42,557 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:42,656 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-01-15 01:43:42,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:42,659 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'
2016-01-15 01:43:42,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:42,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:42,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-15 01:43:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:42,694 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:42,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testSimpleBuffer/simple
2016-01-15 01:43:42,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local5925054_0003
2016-01-15 01:43:42,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:42,919 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:43,029 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:43,030 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:43,039 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EAE674CF006E4E19AB4B9F75105EEE6C, ordinal: 0
2016-01-15 01:43:43,040 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:43,040 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:43,040 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAE674CF006E4E19AB4B9F75105EEE6C, mem on start (mb), free: 118, total: 482, max: 672
2016-01-15 01:43:43,043 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EAE674CF006E4E19AB4B9F75105EEE6C, mem on close (mb), free: 118, total: 482, max: 672
2016-01-15 01:43:43,058 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:43,059 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:43,067 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E977EED215734F51BF6D13D614AE0A25, ordinal: 1
2016-01-15 01:43:43,068 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:43,068 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-15 01:43:43,068 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E977EED215734F51BF6D13D614AE0A25, mem on start (mb), free: 114, total: 482, max: 672
2016-01-15 01:43:43,077 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E977EED215734F51BF6D13D614AE0A25, mem on close (mb), free: 114, total: 482, max: 672
2016-01-15 01:43:43,097 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple/_temporary
2016-01-15 01:43:43,098 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.405
2016-01-15 01:43:43,158 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple
2016-01-15 01:43:43,192 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:43,193 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:43,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-15 01:43:43,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:43,275 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'
2016-01-15 01:43:43,305 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-15 01:43:43,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 01:43:43,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 01:43:43,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-15 01:43:43,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-15 01:43:43,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-15 01:43:43,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-15 01:43:43,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...testJoinerClosure/cogroup
2016-01-15 01:43:43,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1486255496_0004
2016-01-15 01:43:43,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-15 01:43:43,470 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt
2016-01-15 01:43:43,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:43,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:43,583 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, ordinal: 0
2016-01-15 01:43:43,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/upper.txt"]
2016-01-15 01:43:43,585 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-15 01:43:43,586 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, mem on start (mb), free: 59, total: 583, max: 672
2016-01-15 01:43:43,588 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, mem on close (mb), free: 59, total: 583, max: 672
2016-01-15 01:43:43,597 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt
2016-01-15 01:43:43,700 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:43,701 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:43,711 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, ordinal: 0
2016-01-15 01:43:43,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower.txt"]
2016-01-15 01:43:43,712 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-15 01:43:43,713 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, mem on start (mb), free: 6, total: 630, max: 672
2016-01-15 01:43:43,715 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8AAABE4D25D4138B09F60A704C147F9, mem on close (mb), free: 6, total: 630, max: 672
2016-01-15 01:43:43,944 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:43,944 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:43,953 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A4FBAF57E5E04CB391D9315D647B91A7, ordinal: 1
2016-01-15 01:43:43,954 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-15 01:43:43,954 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-15 01:43:43,955 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4FBAF57E5E04CB391D9315D647B91A7, mem on start (mb), free: 231, total: 344, max: 672
2016-01-15 01:43:43,966 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 01:43:43,967 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-15 01:43:43,973 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A4FBAF57E5E04CB391D9315D647B91A7, mem on close (mb), free: 230, total: 344, max: 672
2016-01-15 01:43:43,992 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup/_temporary
2016-01-15 01:43:43,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.687
2016-01-15 01:43:44,042 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup
2016-01-15 01:43:44,059 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:44,060 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:44,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-15 01:43:44,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:44,110 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'
2016-01-15 01:43:44,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:44,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:44,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-15 01:43:44,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:44,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:44,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:44,131 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer2/simple2
2016-01-15 01:43:44,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1018151415_0005
2016-01-15 01:43:44,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:44,240 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:44,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:44,255 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:44,265 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B2CA9B7C01E34D3CB44A343713569ADF, ordinal: 0
2016-01-15 01:43:44,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:44,266 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:44,267 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2CA9B7C01E34D3CB44A343713569ADF, mem on start (mb), free: 76, total: 344, max: 672
2016-01-15 01:43:44,269 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B2CA9B7C01E34D3CB44A343713569ADF, mem on close (mb), free: 76, total: 344, max: 672
2016-01-15 01:43:44,284 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:44,284 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:44,292 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DBF03423EB914DCC800817FF73208F21, ordinal: 1
2016-01-15 01:43:44,292 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:44,293 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-15 01:43:44,293 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBF03423EB914DCC800817FF73208F21, mem on start (mb), free: 72, total: 344, max: 672
2016-01-15 01:43:44,301 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DBF03423EB914DCC800817FF73208F21, mem on close (mb), free: 72, total: 344, max: 672
2016-01-15 01:43:44,328 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2/_temporary
2016-01-15 01:43:44,329 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.200
2016-01-15 01:43:44,383 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2
2016-01-15 01:43:44,405 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:44,406 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:44,458 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-15 01:43:44,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:44,464 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'
2016-01-15 01:43:44,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:44,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 01:43:44,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-15 01:43:44,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:44,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:44,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:44,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer3/simple3
2016-01-15 01:43:44,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local350700443_0006
2016-01-15 01:43:44,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:44,649 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt
2016-01-15 01:43:44,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:44,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:44,673 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EA4E5447C6774C26B8941D37D7ABC41E, ordinal: 0
2016-01-15 01:43:44,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-15 01:43:44,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:44,674 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA4E5447C6774C26B8941D37D7ABC41E, mem on start (mb), free: 201, total: 311, max: 672
2016-01-15 01:43:44,676 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EA4E5447C6774C26B8941D37D7ABC41E, mem on close (mb), free: 201, total: 311, max: 672
2016-01-15 01:43:44,690 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:44,690 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:44,699 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9A210A3D9C349E28B8E951B5E296B89, ordinal: 1
2016-01-15 01:43:44,700 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:44,701 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-15 01:43:44,701 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9A210A3D9C349E28B8E951B5E296B89, mem on start (mb), free: 197, total: 311, max: 672
2016-01-15 01:43:44,708 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9A210A3D9C349E28B8E951B5E296B89, mem on close (mb), free: 197, total: 311, max: 672
2016-01-15 01:43:44,733 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3/_temporary
2016-01-15 01:43:44,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.246
2016-01-15 01:43:44,789 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3
2016-01-15 01:43:44,805 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:44,805 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:44,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-15 01:43:44,848 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:44,848 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'
2016-01-15 01:43:44,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:44,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-15 01:43:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferReverse/firstn
2016-01-15 01:43:44,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local176814776_0007
2016-01-15 01:43:44,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:44,963 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:44,978 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:44,979 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:44,984 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD562D5E33A4469A8FD1C6D23CB2625F, ordinal: 0
2016-01-15 01:43:44,985 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:44,985 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:44,986 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD562D5E33A4469A8FD1C6D23CB2625F, mem on start (mb), free: 158, total: 311, max: 672
2016-01-15 01:43:44,988 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD562D5E33A4469A8FD1C6D23CB2625F, mem on close (mb), free: 157, total: 311, max: 672
2016-01-15 01:43:45,003 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:45,003 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:45,010 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F275A4854CA845B18C02CCA1D12CDDF1, ordinal: 1
2016-01-15 01:43:45,010 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:45,011 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-15 01:43:45,011 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F275A4854CA845B18C02CCA1D12CDDF1, mem on start (mb), free: 153, total: 311, max: 672
2016-01-15 01:43:45,017 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F275A4854CA845B18C02CCA1D12CDDF1, mem on close (mb), free: 152, total: 311, max: 672
2016-01-15 01:43:45,037 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn/_temporary
2016-01-15 01:43:45,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.174
2016-01-15 01:43:45,084 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn
2016-01-15 01:43:45,101 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:45,101 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:45,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.023
2016-01-15 01:43:45,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 01:43:45,153 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 01:43:45,153 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 01:43:45,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-15 01:43:45,207 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-15 01:43:45,207 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'
2016-01-15 01:43:45,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-15 01:43:45,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:45,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-15 01:43:45,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-15 01:43:45,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-15 01:43:45,225 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-15 01:43:45,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFirstNBuffer/firstn
2016-01-15 01:43:45,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1097378242_0008
2016-01-15 01:43:45,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-15 01:43:45,330 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt
2016-01-15 01:43:45,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 01:43:45,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 01:43:45,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C1A911CBEDAC44AD94C895007A417C25, ordinal: 0
2016-01-15 01:43:45,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/classes/test/data/lhs.txt"]
2016-01-15 01:43:45,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:45,375 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1A911CBEDAC44AD94C895007A417C25, mem on start (mb), free: 91, total: 412, max: 672
2016-01-15 01:43:45,378 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C1A911CBEDAC44AD94C895007A417C25, mem on close (mb), free: 91, total: 412, max: 672
2016-01-15 01:43:45,391 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-15 01:43:45,391 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-15 01:43:45,398 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F8F0251FE12749098FE75A4965D66FD0, ordinal: 1
2016-01-15 01:43:45,398 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-15 01:43:45,399 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-15 01:43:45,399 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8F0251FE12749098FE75A4965D66FD0, mem on start (mb), free: 87, total: 412, max: 672
2016-01-15 01:43:45,406 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F8F0251FE12749098FE75A4965D66FD0, mem on close (mb), free: 85, total: 412, max: 672
2016-01-15 01:43:45,431 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn/_temporary
2016-01-15 01:43:45,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.209
2016-01-15 01:43:45,484 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.6.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn