2016-01-14 18:43:41,557 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 18:43:41,578 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BufferPipesPlatformTest, with platform: hadoop2-mr1
2016-01-14 18:43:41,602 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-14 18:43:42,120 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 18:43:42,291 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 18:43:42,410 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:42,413 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-14 18:43:42,523 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: E3045DFEB4714957A3050C31A8096549
2016-01-14 18:43:42,701 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.122
2016-01-14 18:43:42,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:42,704 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-14 18:43:42,869 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 18:43:42,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:42,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:42,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-14 18:43:42,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:42,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:42,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:42,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stIdentityBuffer/identity
2016-01-14 18:43:43,390 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1446878054/.staging/job_local1446878054_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:43,391 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1446878054/.staging/job_local1446878054_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:43,563 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1446878054_0001/job_local1446878054_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:43,564 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1446878054_0001/job_local1446878054_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:43,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1446878054_0001
2016-01-14 18:43:43,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:43,661 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:43,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:43,797 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:43,809 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B0EB3FD8943543FDABD1ACD4CE691210, ordinal: 0
2016-01-14 18:43:43,852 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:43,853 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:43,853 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0EB3FD8943543FDABD1ACD4CE691210, mem on start (mb), free: 144, total: 281, max: 672
2016-01-14 18:43:43,863 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0EB3FD8943543FDABD1ACD4CE691210, mem on close (mb), free: 144, total: 281, max: 672
2016-01-14 18:43:43,975 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:43,976 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:43,986 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DFABEED4256847199AB0223AB12FB33E, ordinal: 1
2016-01-14 18:43:43,989 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:43,989 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-14 18:43:43,990 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFABEED4256847199AB0223AB12FB33E, mem on start (mb), free: 133, total: 281, max: 672
2016-01-14 18:43:44,009 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DFABEED4256847199AB0223AB12FB33E, mem on close (mb), free: 132, total: 281, max: 672
2016-01-14 18:43:44,039 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity/_temporary
2016-01-14 18:43:44,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:01.163
2016-01-14 18:43:44,096 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity
2016-01-14 18:43:44,120 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:44,121 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-14 18:43:44,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 18:43:44,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:44,183 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-14 18:43:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:44,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-14 18:43:44,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:44,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:44,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:44,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferForward/firstn
2016-01-14 18:43:44,300 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity566720087/.staging/job_local566720087_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:44,304 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity566720087/.staging/job_local566720087_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:44,390 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local566720087_0002/job_local566720087_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:44,391 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local566720087_0002/job_local566720087_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:44,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local566720087_0002
2016-01-14 18:43:44,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:44,402 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:44,506 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:44,507 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:44,519 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5ACE7EEE8ED442FB94D14B8DF636A36, ordinal: 0
2016-01-14 18:43:44,520 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:44,520 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:44,521 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5ACE7EEE8ED442FB94D14B8DF636A36, mem on start (mb), free: 83, total: 382, max: 672
2016-01-14 18:43:44,524 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5ACE7EEE8ED442FB94D14B8DF636A36, mem on close (mb), free: 83, total: 382, max: 672
2016-01-14 18:43:44,547 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:44,547 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:44,559 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9D3AB9691B7483F89924A0C545F63CB, ordinal: 1
2016-01-14 18:43:44,560 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:44,560 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-14 18:43:44,560 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9D3AB9691B7483F89924A0C545F63CB, mem on start (mb), free: 79, total: 382, max: 672
2016-01-14 18:43:44,575 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9D3AB9691B7483F89924A0C545F63CB, mem on close (mb), free: 78, total: 382, max: 672
2016-01-14 18:43:44,595 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn/_temporary
2016-01-14 18:43:44,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.384
2016-01-14 18:43:44,695 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn
2016-01-14 18:43:44,733 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:44,734 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-14 18:43:44,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-01-14 18:43:44,807 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:44,807 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-14 18:43:44,831 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:44,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:44,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-14 18:43:44,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:44,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:44,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:44,833 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testSimpleBuffer/simple
2016-01-14 18:43:44,968 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1351995050/.staging/job_local1351995050_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:44,968 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1351995050/.staging/job_local1351995050_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:45,045 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1351995050_0003/job_local1351995050_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:45,045 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1351995050_0003/job_local1351995050_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:45,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1351995050_0003
2016-01-14 18:43:45,047 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:45,059 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:45,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:45,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:45,178 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE8AA52FDF314ACEB464B03A63797501, ordinal: 0
2016-01-14 18:43:45,179 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:45,179 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:45,179 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE8AA52FDF314ACEB464B03A63797501, mem on start (mb), free: 146, total: 482, max: 672
2016-01-14 18:43:45,181 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE8AA52FDF314ACEB464B03A63797501, mem on close (mb), free: 146, total: 482, max: 672
2016-01-14 18:43:45,204 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:45,204 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:45,218 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A75D64F6E15A45B59C93F7D14CB5A924, ordinal: 1
2016-01-14 18:43:45,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:45,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-14 18:43:45,220 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A75D64F6E15A45B59C93F7D14CB5A924, mem on start (mb), free: 143, total: 482, max: 672
2016-01-14 18:43:45,232 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A75D64F6E15A45B59C93F7D14CB5A924, mem on close (mb), free: 142, total: 482, max: 672
2016-01-14 18:43:45,265 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple/_temporary
2016-01-14 18:43:45,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.433
2016-01-14 18:43:45,321 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple
2016-01-14 18:43:45,346 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:45,347 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-14 18:43:45,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-01-14 18:43:45,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:45,438 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-14 18:43:45,471 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 18:43:45,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 18:43:45,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 18:43:45,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-14 18:43:45,472 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 18:43:45,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 18:43:45,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 18:43:45,475 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...testJoinerClosure/cogroup
2016-01-14 18:43:45,543 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1618452955/.staging/job_local1618452955_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:45,543 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1618452955/.staging/job_local1618452955_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:45,587 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1618452955_0004/job_local1618452955_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:45,588 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1618452955_0004/job_local1618452955_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:45,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local1618452955_0004
2016-01-14 18:43:45,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 18:43:45,599 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt
2016-01-14 18:43:45,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:45,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:45,713 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5362031A2654ACC8DBB84D45531709D, ordinal: 0
2016-01-14 18:43:45,715 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/upper.txt"]
2016-01-14 18:43:45,715 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 18:43:45,715 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5362031A2654ACC8DBB84D45531709D, mem on start (mb), free: 93, total: 583, max: 672
2016-01-14 18:43:45,718 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5362031A2654ACC8DBB84D45531709D, mem on close (mb), free: 93, total: 583, max: 672
2016-01-14 18:43:45,728 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt
2016-01-14 18:43:45,835 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:45,836 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:45,849 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F5362031A2654ACC8DBB84D45531709D, ordinal: 0
2016-01-14 18:43:45,850 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower.txt"]
2016-01-14 18:43:45,851 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 18:43:45,851 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5362031A2654ACC8DBB84D45531709D, mem on start (mb), free: 39, total: 630, max: 672
2016-01-14 18:43:45,854 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F5362031A2654ACC8DBB84D45531709D, mem on close (mb), free: 39, total: 630, max: 672
2016-01-14 18:43:45,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:45,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:45,882 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: DAA45294CA364B65B833944A917DAC33, ordinal: 1
2016-01-14 18:43:45,883 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 18:43:45,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-14 18:43:45,884 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DAA45294CA364B65B833944A917DAC33, mem on start (mb), free: 35, total: 630, max: 672
2016-01-14 18:43:45,899 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:43:45,899 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 18:43:45,909 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: DAA45294CA364B65B833944A917DAC33, mem on close (mb), free: 34, total: 630, max: 672
2016-01-14 18:43:45,947 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup/_temporary
2016-01-14 18:43:45,948 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.476
2016-01-14 18:43:45,998 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup
2016-01-14 18:43:46,019 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:46,020 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-14 18:43:46,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-14 18:43:46,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:46,073 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-14 18:43:46,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:46,093 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-14 18:43:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:46,094 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:46,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer2/simple2
2016-01-14 18:43:46,386 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1781036693/.staging/job_local1781036693_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:46,386 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1781036693/.staging/job_local1781036693_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:46,436 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1781036693_0005/job_local1781036693_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:46,436 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1781036693_0005/job_local1781036693_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:46,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1781036693_0005
2016-01-14 18:43:46,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:46,444 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:46,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:46,460 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:46,468 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CFC3D0E0A1974027A03E1081C41B886F, ordinal: 0
2016-01-14 18:43:46,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:46,469 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:46,470 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFC3D0E0A1974027A03E1081C41B886F, mem on start (mb), free: 118, total: 244, max: 672
2016-01-14 18:43:46,474 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CFC3D0E0A1974027A03E1081C41B886F, mem on close (mb), free: 118, total: 244, max: 672
2016-01-14 18:43:46,498 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:46,498 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:46,506 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F4DED48043A94622963099458B789123, ordinal: 1
2016-01-14 18:43:46,507 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:46,507 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-14 18:43:46,507 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4DED48043A94622963099458B789123, mem on start (mb), free: 262, total: 277, max: 672
2016-01-14 18:43:46,516 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F4DED48043A94622963099458B789123, mem on close (mb), free: 261, total: 277, max: 672
2016-01-14 18:43:46,539 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2/_temporary
2016-01-14 18:43:46,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.446
2016-01-14 18:43:46,600 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2
2016-01-14 18:43:46,614 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:46,615 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-14 18:43:46,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 18:43:46,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:46,661 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-14 18:43:46,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:46,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 18:43:46,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-14 18:43:46,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:46,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:46,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:46,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer3/simple3
2016-01-14 18:43:46,743 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1169474288/.staging/job_local1169474288_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:46,743 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1169474288/.staging/job_local1169474288_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:46,781 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1169474288_0006/job_local1169474288_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:46,781 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1169474288_0006/job_local1169474288_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:46,782 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1169474288_0006
2016-01-14 18:43:46,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:46,789 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower+upper.txt
2016-01-14 18:43:46,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:46,823 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:46,831 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E613DB3F70B444D483A8DD2CF958DA34, ordinal: 0
2016-01-14 18:43:46,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 18:43:46,832 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:46,832 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E613DB3F70B444D483A8DD2CF958DA34, mem on start (mb), free: 110, total: 277, max: 672
2016-01-14 18:43:46,834 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E613DB3F70B444D483A8DD2CF958DA34, mem on close (mb), free: 110, total: 277, max: 672
2016-01-14 18:43:46,857 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:46,857 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:46,866 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B58B81FD904E414D825232BE93992898, ordinal: 1
2016-01-14 18:43:46,867 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:46,867 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-14 18:43:46,868 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B58B81FD904E414D825232BE93992898, mem on start (mb), free: 321, total: 339, max: 672
2016-01-14 18:43:46,877 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B58B81FD904E414D825232BE93992898, mem on close (mb), free: 320, total: 339, max: 672
2016-01-14 18:43:46,896 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3/_temporary
2016-01-14 18:43:46,897 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.217
2016-01-14 18:43:46,943 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3
2016-01-14 18:43:46,959 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:46,959 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-14 18:43:46,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 18:43:46,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:46,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 18:43:47,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:47,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:47,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-14 18:43:47,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:47,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:47,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:47,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferReverse/firstn
2016-01-14 18:43:47,070 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1644590603/.staging/job_local1644590603_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:47,071 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity1644590603/.staging/job_local1644590603_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:47,109 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1644590603_0007/job_local1644590603_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:47,109 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1644590603_0007/job_local1644590603_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:47,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1644590603_0007
2016-01-14 18:43:47,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:47,116 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:47,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:47,133 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:47,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DF51D4DE40AC4A68A1EAAB439A818B5A, ordinal: 0
2016-01-14 18:43:47,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:47,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:47,139 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF51D4DE40AC4A68A1EAAB439A818B5A, mem on start (mb), free: 167, total: 339, max: 672
2016-01-14 18:43:47,142 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF51D4DE40AC4A68A1EAAB439A818B5A, mem on close (mb), free: 167, total: 339, max: 672
2016-01-14 18:43:47,158 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:47,158 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:47,166 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E92D37829BFF49B3B91602842B8C890E, ordinal: 1
2016-01-14 18:43:47,167 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:47,167 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-14 18:43:47,168 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E92D37829BFF49B3B91602842B8C890E, mem on start (mb), free: 162, total: 339, max: 672
2016-01-14 18:43:47,179 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E92D37829BFF49B3B91602842B8C890E, mem on close (mb), free: 160, total: 339, max: 672
2016-01-14 18:43:47,198 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn/_temporary
2016-01-14 18:43:47,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.187
2016-01-14 18:43:47,257 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn
2016-01-14 18:43:47,278 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:47,278 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-14 18:43:47,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.017
2016-01-14 18:43:47,300 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 18:43:47,320 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 18:43:47,320 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-14 18:43:47,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 18:43:47,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 18:43:47,360 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-14 18:43:47,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 18:43:47,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:47,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-14 18:43:47,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 18:43:47,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 18:43:47,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 18:43:47,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFirstNBuffer/firstn
2016-01-14 18:43:47,456 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity530890034/.staging/job_local530890034_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:47,456 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/tmp/cascading/staging/teamcity530890034/.staging/job_local530890034_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:47,516 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local530890034_0008/job_local530890034_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 18:43:47,517 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local530890034_0008/job_local530890034_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 18:43:47,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local530890034_0008
2016-01-14 18:43:47,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 18:43:47,525 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt
2016-01-14 18:43:47,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 18:43:47,539 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 18:43:47,546 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A8E42EF85A744C849C3010BE58BA75AE, ordinal: 0
2016-01-14 18:43:47,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/classes/test/data/lhs.txt"]
2016-01-14 18:43:47,547 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:47,547 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8E42EF85A744C849C3010BE58BA75AE, mem on start (mb), free: 232, total: 351, max: 672
2016-01-14 18:43:47,550 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A8E42EF85A744C849C3010BE58BA75AE, mem on close (mb), free: 232, total: 351, max: 672
2016-01-14 18:43:47,565 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 18:43:47,566 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 18:43:47,572 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B9C94076A2324C90AB61E48AED28B725, ordinal: 1
2016-01-14 18:43:47,572 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 18:43:47,573 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-14 18:43:47,573 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9C94076A2324C90AB61E48AED28B725, mem on start (mb), free: 226, total: 351, max: 672
2016-01-14 18:43:47,581 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B9C94076A2324C90AB61E48AED28B725, mem on close (mb), free: 224, total: 351, max: 672
2016-01-14 18:43:47,597 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn/_temporary
2016-01-14 18:43:47,597 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.222
2016-01-14 18:43:47,645 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.3.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn