2016-01-14 23:21:40,804 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 23:21:40,834 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.BufferPipesPlatformTest, with platform: hadoop2-mr1
2016-01-14 23:21:40,870 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-14 23:21:41,503 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 23:21:41,717 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 23:21:41,871 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:41,874 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 23:21:41,989 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5DF7BB9D78AF4423A66D8E22C1FD17D9
2016-01-14 23:21:42,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.112
2016-01-14 23:21:42,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:42,159 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 23:21:42,332 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 23:21:42,333 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:42,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:42,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-14 23:21:42,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:42,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:42,336 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:42,337 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stIdentityBuffer/identity
2016-01-14 23:21:42,918 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1810984243/.staging/job_local1810984243_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:42,931 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1810984243/.staging/job_local1810984243_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:43,068 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1810984243_0001/job_local1810984243_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:43,073 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1810984243_0001/job_local1810984243_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:43,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1810984243_0001
2016-01-14 23:21:43,080 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:43,164 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:43,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:43,304 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:43,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A08A8A3D8FD94C4F9363BE561EC9BC5C, ordinal: 0
2016-01-14 23:21:43,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:43,361 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:43,362 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A08A8A3D8FD94C4F9363BE561EC9BC5C, mem on start (mb), free: 88, total: 223, max: 672
2016-01-14 23:21:43,371 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A08A8A3D8FD94C4F9363BE561EC9BC5C, mem on close (mb), free: 88, total: 223, max: 672
2016-01-14 23:21:43,490 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:43,491 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:43,501 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A6B7ABF52A474BACA8EAAD7D7CF21EA3, ordinal: 1
2016-01-14 23:21:43,505 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:43,506 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-01-14 23:21:43,506 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6B7ABF52A474BACA8EAAD7D7CF21EA3, mem on start (mb), free: 78, total: 223, max: 672
2016-01-14 23:21:43,527 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A6B7ABF52A474BACA8EAAD7D7CF21EA3, mem on close (mb), free: 77, total: 223, max: 672
2016-01-14 23:21:43,559 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity/_temporary
2016-01-14 23:21:43,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:01.225
2016-01-14 23:21:43,619 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity
2016-01-14 23:21:43,646 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:43,647 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 23:21:43,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-01-14 23:21:43,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:43,717 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 23:21:43,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:43,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:43,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-14 23:21:43,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:43,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:43,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:43,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferForward/firstn
2016-01-14 23:21:43,848 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1241094610/.staging/job_local1241094610_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:43,852 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1241094610/.staging/job_local1241094610_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:43,923 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1241094610_0002/job_local1241094610_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:43,926 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1241094610_0002/job_local1241094610_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:43,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1241094610_0002
2016-01-14 23:21:43,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:43,936 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:44,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:44,043 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:44,053 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E31EF73F71A54B23A8CE91FD59140FB3, ordinal: 0
2016-01-14 23:21:44,054 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:44,055 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:44,055 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E31EF73F71A54B23A8CE91FD59140FB3, mem on start (mb), free: 89, total: 323, max: 672
2016-01-14 23:21:44,058 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E31EF73F71A54B23A8CE91FD59140FB3, mem on close (mb), free: 89, total: 323, max: 672
2016-01-14 23:21:44,082 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:44,083 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:44,092 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: B21D045B711A421597E7EC3BF3B3A50D, ordinal: 1
2016-01-14 23:21:44,092 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:44,093 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-01-14 23:21:44,093 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B21D045B711A421597E7EC3BF3B3A50D, mem on start (mb), free: 87, total: 323, max: 672
2016-01-14 23:21:44,105 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: B21D045B711A421597E7EC3BF3B3A50D, mem on close (mb), free: 86, total: 323, max: 672
2016-01-14 23:21:44,144 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn/_temporary
2016-01-14 23:21:44,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.397
2016-01-14 23:21:44,234 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn
2016-01-14 23:21:44,268 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:44,269 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 23:21:44,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2016-01-14 23:21:44,365 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:44,365 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 23:21:44,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:44,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:44,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-14 23:21:44,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:44,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:44,401 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:44,401 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testSimpleBuffer/simple
2016-01-14 23:21:44,592 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity115861519/.staging/job_local115861519_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:44,594 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity115861519/.staging/job_local115861519_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:44,642 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local115861519_0003/job_local115861519_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:44,644 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local115861519_0003/job_local115861519_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:44,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local115861519_0003
2016-01-14 23:21:44,645 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:44,653 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:44,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:44,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:44,721 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C012575858C0415EA52C4AA02B245CF3, ordinal: 0
2016-01-14 23:21:44,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:44,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:44,724 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C012575858C0415EA52C4AA02B245CF3, mem on start (mb), free: 57, total: 382, max: 672
2016-01-14 23:21:44,728 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C012575858C0415EA52C4AA02B245CF3, mem on close (mb), free: 57, total: 382, max: 672
2016-01-14 23:21:44,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:44,768 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:44,778 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: D8BCB55476F1459086673CC8D0842365, ordinal: 1
2016-01-14 23:21:44,779 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:44,780 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-01-14 23:21:44,780 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D8BCB55476F1459086673CC8D0842365, mem on start (mb), free: 170, total: 382, max: 672
2016-01-14 23:21:44,791 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: D8BCB55476F1459086673CC8D0842365, mem on close (mb), free: 170, total: 382, max: 672
2016-01-14 23:21:44,816 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple/_temporary
2016-01-14 23:21:44,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.418
2016-01-14 23:21:44,881 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple
2016-01-14 23:21:44,910 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:44,911 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 23:21:44,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2016-01-14 23:21:44,998 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:44,998 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 23:21:45,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2016-01-14 23:21:45,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 23:21:45,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 23:21:45,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-14 23:21:45,030 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: false
2016-01-14 23:21:45,031 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2016-01-14 23:21:45,031 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2016-01-14 23:21:45,032 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...testJoinerClosure/cogroup
2016-01-14 23:21:45,108 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity612343656/.staging/job_local612343656_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:45,109 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity612343656/.staging/job_local612343656_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:45,167 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local612343656_0004/job_local612343656_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:45,169 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local612343656_0004/job_local612343656_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:45,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_local612343656_0004
2016-01-14 23:21:45,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:8080/
2016-01-14 23:21:45,182 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt
2016-01-14 23:21:45,285 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:45,285 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:45,293 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB1F1127532940C78F0FA9265937CD62, ordinal: 0
2016-01-14 23:21:45,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower.txt"]
2016-01-14 23:21:45,295 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 23:21:45,295 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1F1127532940C78F0FA9265937CD62, mem on start (mb), free: 115, total: 482, max: 672
2016-01-14 23:21:45,296 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1F1127532940C78F0FA9265937CD62, mem on close (mb), free: 115, total: 482, max: 672
2016-01-14 23:21:45,306 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt
2016-01-14 23:21:45,407 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:45,407 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:45,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB1F1127532940C78F0FA9265937CD62, ordinal: 0
2016-01-14 23:21:45,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/upper.txt"]
2016-01-14 23:21:45,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 23:21:45,420 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1F1127532940C78F0FA9265937CD62, mem on start (mb), free: 114, total: 583, max: 672
2016-01-14 23:21:45,422 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB1F1127532940C78F0FA9265937CD62, mem on close (mb), free: 114, total: 583, max: 672
2016-01-14 23:21:45,441 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:45,441 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:45,449 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EC68AFF41B2743C4AEB1F1AC4D01F78F, ordinal: 1
2016-01-14 23:21:45,449 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-01-14 23:21:45,450 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-01-14 23:21:45,450 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC68AFF41B2743C4AEB1F1AC4D01F78F, mem on start (mb), free: 110, total: 583, max: 672
2016-01-14 23:21:45,463 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 23:21:45,463 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-01-14 23:21:45,469 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EC68AFF41B2743C4AEB1F1AC4D01F78F, mem on close (mb), free: 108, total: 583, max: 672
2016-01-14 23:21:45,493 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup/_temporary
2016-01-14 23:21:45,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:00.463
2016-01-14 23:21:45,542 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup
2016-01-14 23:21:45,562 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:45,562 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 23:21:45,612 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-14 23:21:45,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:45,613 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 23:21:45,630 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:45,631 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:45,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-14 23:21:45,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:45,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:45,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:45,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer2/simple2
2016-01-14 23:21:45,697 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity596372830/.staging/job_local596372830_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:45,698 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity596372830/.staging/job_local596372830_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:45,737 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local596372830_0005/job_local596372830_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:45,753 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local596372830_0005/job_local596372830_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:45,755 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local596372830_0005
2016-01-14 23:21:45,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:45,763 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:45,778 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:45,778 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:45,785 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F1EBEB2083174091BD9231E9F8A33BC8, ordinal: 0
2016-01-14 23:21:45,786 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:45,786 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:45,787 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F1EBEB2083174091BD9231E9F8A33BC8, mem on start (mb), free: 184, total: 697, max: 697
2016-01-14 23:21:45,789 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F1EBEB2083174091BD9231E9F8A33BC8, mem on close (mb), free: 184, total: 697, max: 697
2016-01-14 23:21:45,808 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:45,808 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:45,817 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: FCC527F4FA3C4F6ABDB3D502AD6A5C5C, ordinal: 1
2016-01-14 23:21:45,817 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:45,818 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-01-14 23:21:45,818 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCC527F4FA3C4F6ABDB3D502AD6A5C5C, mem on start (mb), free: 178, total: 697, max: 697
2016-01-14 23:21:45,828 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: FCC527F4FA3C4F6ABDB3D502AD6A5C5C, mem on close (mb), free: 176, total: 697, max: 697
2016-01-14 23:21:45,846 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2/_temporary
2016-01-14 23:21:45,847 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.216
2016-01-14 23:21:45,903 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2
2016-01-14 23:21:45,920 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:45,921 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 23:21:45,970 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-14 23:21:45,971 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:45,971 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 23:21:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:45,986 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 23:21:45,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-14 23:21:45,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:45,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:45,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:45,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testSimpleBuffer3/simple3
2016-01-14 23:21:46,063 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1706344038/.staging/job_local1706344038_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,065 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1706344038/.staging/job_local1706344038_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,117 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1706344038_0006/job_local1706344038_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,118 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1706344038_0006/job_local1706344038_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1706344038_0006
2016-01-14 23:21:46,120 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:46,126 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower+upper.txt
2016-01-14 23:21:46,155 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:46,155 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,161 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ECBD690162614A53BFF43FB136F9101D, ordinal: 0
2016-01-14 23:21:46,162 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 23:21:46,162 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,162 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ECBD690162614A53BFF43FB136F9101D, mem on start (mb), free: 179, total: 689, max: 689
2016-01-14 23:21:46,164 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ECBD690162614A53BFF43FB136F9101D, mem on close (mb), free: 179, total: 689, max: 689
2016-01-14 23:21:46,182 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:46,182 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,190 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C78DD5789D494458987EC5C63A0FE801, ordinal: 1
2016-01-14 23:21:46,190 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,191 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-01-14 23:21:46,191 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C78DD5789D494458987EC5C63A0FE801, mem on start (mb), free: 172, total: 689, max: 689
2016-01-14 23:21:46,200 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C78DD5789D494458987EC5C63A0FE801, mem on close (mb), free: 170, total: 689, max: 689
2016-01-14 23:21:46,220 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3/_temporary
2016-01-14 23:21:46,221 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.234
2016-01-14 23:21:46,283 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3
2016-01-14 23:21:46,303 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:46,303 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 23:21:46,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 23:21:46,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:46,342 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 23:21:46,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:46,357 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:46,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-14 23:21:46,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:46,358 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:46,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:46,359 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...irstNBufferReverse/firstn
2016-01-14 23:21:46,422 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1952961616/.staging/job_local1952961616_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,423 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1952961616/.staging/job_local1952961616_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,460 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1952961616_0007/job_local1952961616_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,461 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1952961616_0007/job_local1952961616_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,461 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local1952961616_0007
2016-01-14 23:21:46,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:46,467 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:46,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:46,489 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,498 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F41F75AD8B40418482DB0C8D625AF378, ordinal: 0
2016-01-14 23:21:46,499 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:46,499 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,499 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41F75AD8B40418482DB0C8D625AF378, mem on start (mb), free: 186, total: 695, max: 695
2016-01-14 23:21:46,502 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F41F75AD8B40418482DB0C8D625AF378, mem on close (mb), free: 186, total: 695, max: 695
2016-01-14 23:21:46,523 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:46,523 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,531 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: A0A27CED1EBF46B99D4AA9477AFEBEC8, ordinal: 1
2016-01-14 23:21:46,532 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,533 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-01-14 23:21:46,533 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A0A27CED1EBF46B99D4AA9477AFEBEC8, mem on start (mb), free: 179, total: 695, max: 695
2016-01-14 23:21:46,543 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: A0A27CED1EBF46B99D4AA9477AFEBEC8, mem on close (mb), free: 177, total: 695, max: 695
2016-01-14 23:21:46,565 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn/_temporary
2016-01-14 23:21:46,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.208
2016-01-14 23:21:46,611 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn
2016-01-14 23:21:46,627 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:46,627 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 23:21:46,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.016
2016-01-14 23:21:46,648 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-14 23:21:46,664 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 23:21:46,664 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 23:21:46,698 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 23:21:46,699 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 23:21:46,699 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 23:21:46,713 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 23:21:46,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:46,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-14 23:21:46,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: false
2016-01-14 23:21:46,714 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2016-01-14 23:21:46,715 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2016-01-14 23:21:46,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFirstNBuffer/firstn
2016-01-14 23:21:46,783 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity794545596/.staging/job_local794545596_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,784 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity794545596/.staging/job_local794545596_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,825 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local794545596_0008/job_local794545596_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2016-01-14 23:21:46,827 WARN conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local794545596_0008/job_local794545596_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2016-01-14 23:21:46,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_local794545596_0008
2016-01-14 23:21:46,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:8080/
2016-01-14 23:21:46,833 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt
2016-01-14 23:21:46,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 23:21:46,855 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,861 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E9F534A8D3634C2C97913F96D09E5D85, ordinal: 0
2016-01-14 23:21:46,862 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/lhs.txt"]
2016-01-14 23:21:46,862 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,862 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9F534A8D3634C2C97913F96D09E5D85, mem on start (mb), free: 174, total: 685, max: 685
2016-01-14 23:21:46,865 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E9F534A8D3634C2C97913F96D09E5D85, mem on close (mb), free: 174, total: 685, max: 685
2016-01-14 23:21:46,881 INFO hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.0.4
2016-01-14 23:21:46,881 INFO hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-01-14 23:21:46,888 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C032A8B4E8D143FFA7F6DCFAB6DD4B23, ordinal: 1
2016-01-14 23:21:46,888 INFO hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-01-14 23:21:46,889 INFO hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-01-14 23:21:46,889 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C032A8B4E8D143FFA7F6DCFAB6DD4B23, mem on start (mb), free: 168, total: 685, max: 685
2016-01-14 23:21:46,898 INFO hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C032A8B4E8D143FFA7F6DCFAB6DD4B23, mem on close (mb), free: 167, total: 685, max: 685
2016-01-14 23:21:46,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn/_temporary
2016-01-14 23:21:46,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.205
2016-01-14 23:21:46,966 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn