Class cascading.BufferPipesPlatformTest

9

tests

0

failures

0

ignored

5.858s

duration

100%

successful

Tests

Test Duration Result
testFirstNBuffer 0.346s passed
testFirstNBufferForward 0.476s passed
testFirstNBufferReverse 0.314s passed
testIdentityBuffer 2.741s passed
testJoinerClosure 0.463s passed
testJoinerClosureFail 0.041s passed
testSimpleBuffer 0.701s passed
testSimpleBuffer2 0.372s passed
testSimpleBuffer3 0.404s passed

Standard output

2016-05-17 22:01:10,642 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:01:10,673 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.BufferPipesPlatformTest, with platform: hadoop2-mr1
2016-05-17 22:01:10,706 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-17 22:01:11,329 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 22:01:11,471 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-17 22:01:11,591 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:11,593 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:11,703 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 53E42E7D223C4F0691D599630023EA1C
2016-05-17 22:01:11,895 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.126
2016-05-17 22:01:11,898 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:11,898 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:12,069 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:01:12,072 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:12,073 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:12,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-05-17 22:01:12,074 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:12,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:12,077 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:12,078 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...stIdentityBuffer/identity
2016-05-17 22:01:12,598 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2050912133/.staging/job_local2050912133_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:12,610 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2050912133/.staging/job_local2050912133_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:12,753 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2050912133_0001/job_local2050912133_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:12,754 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2050912133_0001/job_local2050912133_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:12,764 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local2050912133_0001
2016-05-17 22:01:12,765 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:12,844 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:13,203 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:13,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:13,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6AF9CE233DD43DFAACDE2A6AA93E4D7, ordinal: 0
2016-05-17 22:01:13,252 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:13,253 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:13,254 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6AF9CE233DD43DFAACDE2A6AA93E4D7, mem on start (mb), free: 388, total: 501, max: 672
2016-05-17 22:01:13,263 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6AF9CE233DD43DFAACDE2A6AA93E4D7, mem on close (mb), free: 387, total: 501, max: 672
2016-05-17 22:01:13,301 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:13,301 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:13,312 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C0EB03EBADE7425BAD6A51C7B07B3748, ordinal: 1
2016-05-17 22:01:13,315 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:13,315 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity"]
2016-05-17 22:01:13,316 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0EB03EBADE7425BAD6A51C7B07B3748, mem on start (mb), free: 384, total: 501, max: 672
2016-05-17 22:01:13,338 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C0EB03EBADE7425BAD6A51C7B07B3748, mem on close (mb), free: 383, total: 501, max: 672
2016-05-17 22:01:13,369 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity/_temporary
2016-05-17 22:01:13,369 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:01.295
2016-05-17 22:01:13,444 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testIdentityBuffer/identity
2016-05-17 22:01:13,467 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:13,468 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:13,537 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2016-05-17 22:01:13,539 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:13,539 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:13,569 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:13,570 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:13,571 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-05-17 22:01:13,572 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:13,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:13,573 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:13,574 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...irstNBufferForward/firstn
2016-05-17 22:01:13,652 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1920166494/.staging/job_local1920166494_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:13,656 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1920166494/.staging/job_local1920166494_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:13,718 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1920166494_0002/job_local1920166494_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:13,719 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1920166494_0002/job_local1920166494_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:13,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1920166494_0002
2016-05-17 22:01:13,722 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:13,729 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:13,753 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:13,754 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:13,764 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA5EE22400CF4B78B068DBCFC1F75085, ordinal: 0
2016-05-17 22:01:13,766 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:13,766 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:13,766 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA5EE22400CF4B78B068DBCFC1F75085, mem on start (mb), free: 232, total: 501, max: 672
2016-05-17 22:01:13,771 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA5EE22400CF4B78B068DBCFC1F75085, mem on close (mb), free: 232, total: 501, max: 672
2016-05-17 22:01:13,788 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:13,788 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:13,803 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: BD912B99FD204E5D91FF1C13448D8763, ordinal: 1
2016-05-17 22:01:13,803 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:13,804 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn"]
2016-05-17 22:01:13,804 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD912B99FD204E5D91FF1C13448D8763, mem on start (mb), free: 231, total: 501, max: 672
2016-05-17 22:01:13,818 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: BD912B99FD204E5D91FF1C13448D8763, mem on close (mb), free: 230, total: 501, max: 672
2016-05-17 22:01:13,846 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn/_temporary
2016-05-17 22:01:13,847 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.277
2016-05-17 22:01:13,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferForward/firstn
2016-05-17 22:01:13,946 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:13,947 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:14,044 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-05-17 22:01:14,046 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:14,047 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:14,083 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:14,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:14,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-05-17 22:01:14,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:14,084 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:14,085 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:14,087 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...m/testSimpleBuffer/simple
2016-05-17 22:01:14,232 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1593757782/.staging/job_local1593757782_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:14,235 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1593757782/.staging/job_local1593757782_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:14,298 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1593757782_0003/job_local1593757782_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:14,298 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1593757782_0003/job_local1593757782_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:14,300 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1593757782_0003
2016-05-17 22:01:14,301 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:14,311 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:14,410 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:14,411 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:14,419 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D5DB6A60813846DF8F1AEE764D1173BE, ordinal: 0
2016-05-17 22:01:14,420 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:14,420 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:14,421 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5DB6A60813846DF8F1AEE764D1173BE, mem on start (mb), free: 82, total: 501, max: 672
2016-05-17 22:01:14,423 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D5DB6A60813846DF8F1AEE764D1173BE, mem on close (mb), free: 82, total: 501, max: 672
2016-05-17 22:01:14,437 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:14,437 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:14,446 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: EBB213DDA6774838B1F80E5ED983E17B, ordinal: 1
2016-05-17 22:01:14,447 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:14,448 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple"]
2016-05-17 22:01:14,448 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBB213DDA6774838B1F80E5ED983E17B, mem on start (mb), free: 80, total: 501, max: 672
2016-05-17 22:01:14,463 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: EBB213DDA6774838B1F80E5ED983E17B, mem on close (mb), free: 79, total: 501, max: 672
2016-05-17 22:01:14,491 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple/_temporary
2016-05-17 22:01:14,492 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.408
2016-05-17 22:01:14,623 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer/simple
2016-05-17 22:01:14,642 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:14,643 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:14,729 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-05-17 22:01:14,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:14,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:14,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-17 22:01:14,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]
2016-05-17 22:01:14,759 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 22:01:14,760 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-05-17 22:01:14,761 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  parallel execution of steps is enabled: false
2016-05-17 22:01:14,761 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  executing total steps: 1
2016-05-17 22:01:14,762 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  allocating management threads: 1
2016-05-17 22:01:14,763 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...testJoinerClosure/cogroup
2016-05-17 22:01:14,829 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1361043585/.staging/job_local1361043585_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:14,832 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1361043585/.staging/job_local1361043585_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:14,870 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1361043585_0004/job_local1361043585_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:14,870 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1361043585_0004/job_local1361043585_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:14,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted hadoop job: job_local1361043585_0004
2016-05-17 22:01:14,872 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tracking url: http://localhost:8080/
2016-05-17 22:01:14,882 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt
2016-05-17 22:01:14,900 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:14,901 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:14,910 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, ordinal: 0
2016-05-17 22:01:14,913 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower.txt"]
2016-05-17 22:01:14,913 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 22:01:14,914 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, mem on start (mb), free: 261, total: 416, max: 672
2016-05-17 22:01:14,916 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, mem on close (mb), free: 261, total: 416, max: 672
2016-05-17 22:01:14,926 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt
2016-05-17 22:01:14,942 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:14,943 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:14,953 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, ordinal: 0
2016-05-17 22:01:14,954 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/upper.txt"]
2016-05-17 22:01:14,955 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 22:01:14,955 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, mem on start (mb), free: 159, total: 416, max: 672
2016-05-17 22:01:14,957 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F9DA921B681F4595955DD4CBC8DD597D, mem on close (mb), free: 159, total: 416, max: 672
2016-05-17 22:01:14,976 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:14,976 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:14,984 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AB054B74CAD84C6FA6278DFDFCF2A1DE, ordinal: 1
2016-05-17 22:01:14,985 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:'num'] upper:[{1}:'num']]
2016-05-17 22:01:14,985 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup"]
2016-05-17 22:01:14,986 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AB054B74CAD84C6FA6278DFDFCF2A1DE, mem on start (mb), free: 158, total: 416, max: 672
2016-05-17 22:01:15,001 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(89)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:01:15,002 INFO  collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(94)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2016-05-17 22:01:15,009 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AB054B74CAD84C6FA6278DFDFCF2A1DE, mem on close (mb), free: 156, total: 416, max: 672
2016-05-17 22:01:15,038 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup/_temporary
2016-05-17 22:01:15,039 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper]  completed in: 00:00.280
2016-05-17 22:01:15,086 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testJoinerClosure/cogroup
2016-05-17 22:01:15,102 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:15,102 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:15,150 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 22:01:15,151 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:15,152 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:15,170 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:15,171 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:15,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-05-17 22:01:15,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:15,172 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:15,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:15,173 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...testSimpleBuffer2/simple2
2016-05-17 22:01:15,245 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1279390758/.staging/job_local1279390758_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:15,246 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1279390758/.staging/job_local1279390758_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:15,293 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1279390758_0005/job_local1279390758_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:15,294 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1279390758_0005/job_local1279390758_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:15,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1279390758_0005
2016-05-17 22:01:15,295 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:15,301 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:15,333 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:15,334 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:15,341 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2A9E5F15A7F4C3C89119EB017A58420, ordinal: 0
2016-05-17 22:01:15,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:15,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:15,342 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2A9E5F15A7F4C3C89119EB017A58420, mem on start (mb), free: 107, total: 517, max: 672
2016-05-17 22:01:15,345 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2A9E5F15A7F4C3C89119EB017A58420, mem on close (mb), free: 107, total: 517, max: 672
2016-05-17 22:01:15,359 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:15,359 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:15,369 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: E6E870030B5F4B5483742C09878F34A3, ordinal: 1
2016-05-17 22:01:15,370 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:15,370 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2"]
2016-05-17 22:01:15,370 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6E870030B5F4B5483742C09878F34A3, mem on start (mb), free: 106, total: 517, max: 672
2016-05-17 22:01:15,381 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: E6E870030B5F4B5483742C09878F34A3, mem on close (mb), free: 105, total: 517, max: 672
2016-05-17 22:01:15,406 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2/_temporary
2016-05-17 22:01:15,407 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.236
2016-05-17 22:01:15,458 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer2/simple2
2016-05-17 22:01:15,478 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:15,479 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:15,607 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:01:15,608 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:15,608 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:15,622 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:15,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-17 22:01:15,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-05-17 22:01:15,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:15,623 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:15,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:15,624 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...testSimpleBuffer3/simple3
2016-05-17 22:01:15,688 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1978092161/.staging/job_local1978092161_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:15,691 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1978092161/.staging/job_local1978092161_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:15,726 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1978092161_0006/job_local1978092161_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:15,726 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1978092161_0006/job_local1978092161_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:15,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1978092161_0006
2016-05-17 22:01:15,729 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:15,738 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower+upper.txt
2016-05-17 22:01:15,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:15,753 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:15,759 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C58755F9CB0F43DEAB52E66A57A4E4A2, ordinal: 0
2016-05-17 22:01:15,759 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lower+upper.txt"]
2016-05-17 22:01:15,760 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:15,760 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C58755F9CB0F43DEAB52E66A57A4E4A2, mem on start (mb), free: 284, total: 427, max: 672
2016-05-17 22:01:15,761 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C58755F9CB0F43DEAB52E66A57A4E4A2, mem on close (mb), free: 284, total: 427, max: 672
2016-05-17 22:01:15,773 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:15,773 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:15,781 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: C7A5C90D54A34D6097E28A6937589F97, ordinal: 1
2016-05-17 22:01:15,783 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:15,783 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3"]
2016-05-17 22:01:15,784 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7A5C90D54A34D6097E28A6937589F97, mem on start (mb), free: 281, total: 427, max: 672
2016-05-17 22:01:15,795 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: C7A5C90D54A34D6097E28A6937589F97, mem on close (mb), free: 281, total: 427, max: 672
2016-05-17 22:01:15,819 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3/_temporary
2016-05-17 22:01:15,820 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.197
2016-05-17 22:01:15,863 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testSimpleBuffer3/simple3
2016-05-17 22:01:15,887 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:15,890 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:15,932 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-17 22:01:15,934 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:15,935 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:15,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:15,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:15,953 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-05-17 22:01:15,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:15,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:15,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:15,954 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...irstNBufferReverse/firstn
2016-05-17 22:01:16,012 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2107570761/.staging/job_local2107570761_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:16,013 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2107570761/.staging/job_local2107570761_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:16,050 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2107570761_0007/job_local2107570761_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:16,050 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2107570761_0007/job_local2107570761_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:16,051 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local2107570761_0007
2016-05-17 22:01:16,052 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:16,057 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:16,072 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:16,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:16,078 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE554E6139A1414C9C16A5C862609421, ordinal: 0
2016-05-17 22:01:16,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:16,079 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:16,080 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE554E6139A1414C9C16A5C862609421, mem on start (mb), free: 130, total: 427, max: 672
2016-05-17 22:01:16,082 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE554E6139A1414C9C16A5C862609421, mem on close (mb), free: 130, total: 427, max: 672
2016-05-17 22:01:16,094 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:16,094 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:16,101 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: AAF48FDBBD5D4F11B12B828B26DE2CB2, ordinal: 1
2016-05-17 22:01:16,102 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:16,102 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn"]
2016-05-17 22:01:16,102 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AAF48FDBBD5D4F11B12B828B26DE2CB2, mem on start (mb), free: 128, total: 427, max: 672
2016-05-17 22:01:16,113 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: AAF48FDBBD5D4F11B12B828B26DE2CB2, mem on close (mb), free: 127, total: 427, max: 672
2016-05-17 22:01:16,132 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn/_temporary
2016-05-17 22:01:16,133 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.179
2016-05-17 22:01:16,177 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBufferReverse/firstn
2016-05-17 22:01:16,192 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:16,193 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:16,217 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2016-05-17 22:01:16,218 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-05-17 22:01:16,234 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:01:16,235 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:01:16,275 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-17 22:01:16,276 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-17 22:01:16,276 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:01:16,334 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting
2016-05-17 22:01:16,334 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  source: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:16,335 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  sink: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-05-17 22:01:16,335 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  parallel execution of steps is enabled: false
2016-05-17 22:01:16,335 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  executing total steps: 1
2016-05-17 22:01:16,335 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  allocating management threads: 1
2016-05-17 22:01:16,336 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] starting step: (1/1) ...m/testFirstNBuffer/firstn
2016-05-17 22:01:16,398 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1800558121/.staging/job_local1800558121_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:16,400 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1800558121/.staging/job_local1800558121_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:16,434 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1800558121_0008/job_local1800558121_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:01:16,434 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1800558121_0008/job_local1800558121_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:01:16,435 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] submitted hadoop job: job_local1800558121_0008
2016-05-17 22:01:16,436 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tracking url: http://localhost:8080/
2016-05-17 22:01:16,443 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt
2016-05-17 22:01:16,458 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:01:16,458 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:01:16,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C3E4DCDB2E5A4EBF9F86A86F457D826E, ordinal: 0
2016-05-17 22:01:16,465 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/lhs.txt"]
2016-05-17 22:01:16,465 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:16,466 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E4DCDB2E5A4EBF9F86A86F457D826E, mem on start (mb), free: 301, total: 442, max: 672
2016-05-17 22:01:16,469 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C3E4DCDB2E5A4EBF9F86A86F457D826E, mem on close (mb), free: 301, total: 442, max: 672
2016-05-17 22:01:16,482 INFO  hadoop.FlowReducer (FlowReducer.java:configure(83)) - cascading version: 3.1.0
2016-05-17 22:01:16,482 INFO  hadoop.FlowReducer (FlowReducer.java:configure(84)) - child jvm opts: -Xmx200m
2016-05-17 22:01:16,489 INFO  hadoop.FlowReducer (FlowReducer.java:configure(97)) - flow node id: F93A1A76DCA04E9388EDB02F8D2E90BF, ordinal: 1
2016-05-17 22:01:16,490 INFO  hadoop.FlowReducer (FlowReducer.java:configure(104)) - sourcing from: GroupBy(test)[by:[{1}:'num']]
2016-05-17 22:01:16,490 INFO  hadoop.FlowReducer (FlowReducer.java:configure(107)) - sinking to: Hfs["TextDelimited[['num', 'lower']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn"]
2016-05-17 22:01:16,490 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F93A1A76DCA04E9388EDB02F8D2E90BF, mem on start (mb), free: 299, total: 442, max: 672
2016-05-17 22:01:16,501 INFO  hadoop.FlowReducer (LogUtil.java:logMemory(59)) - flow node id: F93A1A76DCA04E9388EDB02F8D2E90BF, mem on close (mb), free: 298, total: 442, max: 672
2016-05-17 22:01:16,523 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn/_temporary
2016-05-17 22:01:16,523 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [test]  completed in: 00:00.189
2016-05-17 22:01:16,565 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/bufferpipesplatform/testFirstNBuffer/firstn