2015-08-14 02:51:21,019 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 02:51:21,086 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 02:51:21,086 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.BasicPipesPlatformTest
2015-08-14 02:51:21,128 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 02:51:21,760 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 02:51:21,917 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 02:51:22,052 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:22,054 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:22,067 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 1E1688040D884954BA9CD827BCA049FB
2015-08-14 02:51:22,343 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 02:51:22,345 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:22,345 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:22,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplechain"]
2015-08-14 02:51:22,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:22,346 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 2
2015-08-14 02:51:22,347 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:22,350 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/2)
2015-08-14 02:51:23,049 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1384595823/.staging/job_local1384595823_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:23,051 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1384595823/.staging/job_local1384595823_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:23,234 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1384595823_0001/job_local1384595823_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:23,236 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1384595823_0001/job_local1384595823_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:23,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1384595823_0001
2015-08-14 02:51:23,251 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:23,369 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:23,556 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:23,557 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:23,626 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:23,627 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:23,812 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:23,813 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:23,831 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:23,831 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: TempHfs["SequenceFile[[0, 'count']]"][6043101293/test/]
2015-08-14 02:51:23,913 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (2/2) ...pipesplatform/simplechain
2015-08-14 02:51:24,051 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1504921943/.staging/job_local1504921943_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:24,052 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1504921943/.staging/job_local1504921943_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:24,148 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1504921943_0002/job_local1504921943_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:24,149 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1504921943_0002/job_local1504921943_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:24,151 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1504921943_0002
2015-08-14 02:51:24,151 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:24,160 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/hadoop-teamcity/6043101293_test_40F8DC9E1B304AB596DBA9E51D0B5D15/part-00000
2015-08-14 02:51:24,316 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:24,317 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:24,329 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: TempHfs["SequenceFile[[0, 'count']]"][6043101293/test/]
2015-08-14 02:51:24,330 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:24,363 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:24,363 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:24,375 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:24,376 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplechain"]
2015-08-14 02:51:24,432 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplechain/_temporary
2015-08-14 02:51:24,478 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/simplechain
2015-08-14 02:51:24,510 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:24,511 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:24,540 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-14 02:51:24,540 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:24,540 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count"]
2015-08-14 02:51:24,541 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-08-14 02:51:24,541 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-08-14 02:51:24,541 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-08-14 02:51:24,542 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) .../basicpipesplatform/count
2015-08-14 02:51:24,685 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1023021442/.staging/job_local1023021442_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:24,686 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1023021442/.staging/job_local1023021442_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:24,758 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1023021442_0003/job_local1023021442_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:24,759 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1023021442_0003/job_local1023021442_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:24,761 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local1023021442_0003
2015-08-14 02:51:24,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-14 02:51:24,773 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt
2015-08-14 02:51:24,920 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:24,922 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:24,932 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:24,933 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:24,971 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:24,972 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:24,982 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:24,983 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count"]
2015-08-14 02:51:25,040 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count/_temporary
2015-08-14 02:51:25,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/count
2015-08-14 02:51:25,176 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:25,177 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:25,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:25,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:25,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/swap"]
2015-08-14 02:51:25,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:25,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:25,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:25,208 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...1/basicpipesplatform/swap
2015-08-14 02:51:25,305 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2081779972/.staging/job_local2081779972_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:25,306 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2081779972/.staging/job_local2081779972_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:25,379 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2081779972_0004/job_local2081779972_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:25,380 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2081779972_0004/job_local2081779972_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:25,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2081779972_0004
2015-08-14 02:51:25,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:25,391 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:25,404 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:25,404 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:25,413 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:25,414 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/swap"]
2015-08-14 02:51:25,440 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/swap/_temporary
2015-08-14 02:51:25,479 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/swap
2015-08-14 02:51:25,508 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:25,508 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:25,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:25,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 02:51:25,537 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/ungrouped"]
2015-08-14 02:51:25,537 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:25,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:25,538 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:25,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/ungrouped
2015-08-14 02:51:25,632 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity175882066/.staging/job_local175882066_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:25,633 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity175882066/.staging/job_local175882066_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:25,701 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local175882066_0005/job_local175882066_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:25,702 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local175882066_0005/job_local175882066_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:25,704 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local175882066_0005
2015-08-14 02:51:25,704 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:25,715 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower+upper.txt
2015-08-14 02:51:25,727 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:25,727 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:25,737 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 02:51:25,738 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/ungrouped"]
2015-08-14 02:51:25,771 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/ungrouped/_temporary
2015-08-14 02:51:25,810 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/ungrouped
2015-08-14 02:51:25,860 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:25,860 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:25,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:51:25,903 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 02:51:25,904 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:25,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogrouprelativeunknown"]
2015-08-14 02:51:25,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: false
2015-08-14 02:51:25,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 02:51:25,906 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 02:51:25,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...lexcogrouprelativeunknown
2015-08-14 02:51:25,999 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity468050293/.staging/job_local468050293_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:25,999 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity468050293/.staging/job_local468050293_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:26,055 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local468050293_0006/job_local468050293_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:26,055 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local468050293_0006/job_local468050293_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:26,056 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local468050293_0006
2015-08-14 02:51:26,057 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-14 02:51:26,064 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt
2015-08-14 02:51:26,207 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:26,208 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:26,218 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 02:51:26,219 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-14 02:51:26,235 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt
2015-08-14 02:51:26,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:26,376 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:26,385 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:26,386 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-14 02:51:26,415 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:26,416 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:26,425 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:-2] upper:[{1}:-2]]
2015-08-14 02:51:26,426 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogrouprelativeunknown"]
2015-08-14 02:51:26,443 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:26,444 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:26,487 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogrouprelativeunknown/_temporary
2015-08-14 02:51:26,556 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/complexcogrouprelativeunknown
2015-08-14 02:51:26,860 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:26,861 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:26,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:26,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:26,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelative"]
2015-08-14 02:51:26,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:26,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:26,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:26,889 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...esplatform/simplerelative
2015-08-14 02:51:26,980 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity839233294/.staging/job_local839233294_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:26,981 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity839233294/.staging/job_local839233294_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:27,037 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local839233294_0007/job_local839233294_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:27,038 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local839233294_0007/job_local839233294_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:27,039 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local839233294_0007
2015-08-14 02:51:27,040 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:27,047 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:27,119 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:27,119 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:27,129 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:27,129 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:27,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:27,156 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:27,165 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:27,165 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelative"]
2015-08-14 02:51:27,211 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelative/_temporary
2015-08-14 02:51:27,245 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/simplerelative
2015-08-14 02:51:27,400 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:27,401 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:27,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:27,439 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:27,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simpleresult"]
2015-08-14 02:51:27,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:27,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:27,440 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:27,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...ipesplatform/simpleresult
2015-08-14 02:51:27,532 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2059857821/.staging/job_local2059857821_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:27,532 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2059857821/.staging/job_local2059857821_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:27,588 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2059857821_0008/job_local2059857821_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:27,588 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2059857821_0008/job_local2059857821_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:27,590 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local2059857821_0008
2015-08-14 02:51:27,590 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:27,597 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt
2015-08-14 02:51:27,742 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:27,743 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:27,754 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:27,754 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:27,874 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:27,875 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:27,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:27,884 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simpleresult"]
2015-08-14 02:51:27,923 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simpleresult/_temporary
2015-08-14 02:51:27,957 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/simpleresult
2015-08-14 02:51:27,980 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:27,981 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:27,999 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:28,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:28,001 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filterall"]
2015-08-14 02:51:28,002 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:28,003 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:28,004 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:28,005 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...icpipesplatform/filterall
2015-08-14 02:51:28,110 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1470545287/.staging/job_local1470545287_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,111 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1470545287/.staging/job_local1470545287_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,165 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1470545287_0009/job_local1470545287_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,165 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1470545287_0009/job_local1470545287_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,166 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1470545287_0009
2015-08-14 02:51:28,167 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:28,174 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:28,183 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:28,184 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:28,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:28,191 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filterall"]
2015-08-14 02:51:28,221 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filterall/_temporary
2015-08-14 02:51:28,255 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/filterall
2015-08-14 02:51:28,280 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:28,281 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:28,303 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:28,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:28,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelativeunknown"]
2015-08-14 02:51:28,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:28,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:28,304 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:28,305 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...orm/simplerelativeunknown
2015-08-14 02:51:28,390 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity9669169/.staging/job_local9669169_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,390 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity9669169/.staging/job_local9669169_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,446 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local9669169_0010/job_local9669169_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,446 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local9669169_0010/job_local9669169_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,448 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local9669169_0010
2015-08-14 02:51:28,448 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:28,456 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt
2015-08-14 02:51:28,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:28,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:28,608 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:28,609 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:-1]]
2015-08-14 02:51:28,635 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:28,636 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:28,644 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:-1]]
2015-08-14 02:51:28,644 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelativeunknown"]
2015-08-14 02:51:28,679 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simplerelativeunknown/_temporary
2015-08-14 02:51:28,715 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/simplerelativeunknown
2015-08-14 02:51:28,741 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:28,742 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:28,770 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 02:51:28,770 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 02:51:28,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:28,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogroup"]
2015-08-14 02:51:28,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: false
2015-08-14 02:51:28,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 02:51:28,773 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 02:51:28,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/complexcogroup
2015-08-14 02:51:28,865 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity167422945/.staging/job_local167422945_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,866 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity167422945/.staging/job_local167422945_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,916 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local167422945_0011/job_local167422945_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:28,916 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local167422945_0011/job_local167422945_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:28,917 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_local167422945_0011
2015-08-14 02:51:28,918 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://localhost:8080/
2015-08-14 02:51:28,924 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt
2015-08-14 02:51:29,066 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:29,066 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:29,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/upper.txt"]
2015-08-14 02:51:29,075 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-14 02:51:29,088 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt
2015-08-14 02:51:29,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:29,384 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:29,393 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/lower.txt"]
2015-08-14 02:51:29,394 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-14 02:51:29,421 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:29,422 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:29,429 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: CoGroup(lower*upper)[by: lower:[{1}:0] upper:[{1}:0]]
2015-08-14 02:51:29,430 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogroup"]
2015-08-14 02:51:29,439 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(105)) - attempting to load codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:29,439 INFO collect.SpillableTupleList (SpillableTupleList.java:getCodecClass(110)) - found codec: org.apache.hadoop.io.compress.GzipCodec
2015-08-14 02:51:29,474 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/complexcogroup/_temporary
2015-08-14 02:51:29,622 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/complexcogroup
2015-08-14 02:51:29,642 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:29,642 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:29,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:29,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:29,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/replace"]
2015-08-14 02:51:29,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:29,658 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:29,659 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:29,659 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...asicpipesplatform/replace
2015-08-14 02:51:29,737 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity518085229/.staging/job_local518085229_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:29,737 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity518085229/.staging/job_local518085229_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:29,787 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local518085229_0012/job_local518085229_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:29,787 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local518085229_0012/job_local518085229_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:29,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local518085229_0012
2015-08-14 02:51:29,789 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:29,794 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:29,803 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:29,804 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:29,810 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:29,811 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/replace"]
2015-08-14 02:51:29,833 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/replace/_temporary
2015-08-14 02:51:29,867 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/replace
2015-08-14 02:51:29,887 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:29,887 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:29,904 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-14 02:51:29,904 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:29,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count2"]
2015-08-14 02:51:29,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-08-14 02:51:29,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-08-14 02:51:29,905 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-08-14 02:51:29,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count2
2015-08-14 02:51:29,982 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity931715578/.staging/job_local931715578_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:29,982 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity931715578/.staging/job_local931715578_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,035 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local931715578_0013/job_local931715578_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:30,036 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local931715578_0013/job_local931715578_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,039 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local931715578_0013
2015-08-14 02:51:30,039 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-14 02:51:30,045 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt
2015-08-14 02:51:30,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:30,188 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,195 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:30,196 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:30,220 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,226 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,227 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count2"]
2015-08-14 02:51:30,260 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count2/_temporary
2015-08-14 02:51:30,328 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/count2
2015-08-14 02:51:30,356 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:30,356 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:30,373 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-14 02:51:30,374 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:30,375 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count3"]
2015-08-14 02:51:30,375 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-08-14 02:51:30,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-08-14 02:51:30,376 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-08-14 02:51:30,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count3
2015-08-14 02:51:30,454 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity438080902/.staging/job_local438080902_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:30,454 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity438080902/.staging/job_local438080902_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,502 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local438080902_0014/job_local438080902_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:30,502 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local438080902_0014/job_local438080902_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local438080902_0014
2015-08-14 02:51:30,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-14 02:51:30,510 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt
2015-08-14 02:51:30,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:30,573 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:30,581 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,608 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:30,608 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,615 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,615 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count3"]
2015-08-14 02:51:30,653 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count3/_temporary
2015-08-14 02:51:30,724 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/count3
2015-08-14 02:51:30,754 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:30,754 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:30,770 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting
2015-08-14 02:51:30,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:30,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count4"]
2015-08-14 02:51:30,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] parallel execution is enabled: false
2015-08-14 02:51:30,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] starting jobs: 1
2015-08-14 02:51:30,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [count] allocating threads: 1
2015-08-14 02:51:30,772 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] starting step: (1/1) ...basicpipesplatform/count4
2015-08-14 02:51:30,851 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998564625/.staging/job_local998564625_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:30,852 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity998564625/.staging/job_local998564625_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,902 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998564625_0015/job_local998564625_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:30,903 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local998564625_0015/job_local998564625_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:30,905 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] submitted hadoop job: job_local998564625_0015
2015-08-14 02:51:30,905 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [count] tracking url: http://localhost:8080/
2015-08-14 02:51:30,911 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt
2015-08-14 02:51:30,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:30,936 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:51:30,943 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,968 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:30,968 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:30,975 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(count)[by:[{1}:1]]
2015-08-14 02:51:30,975 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count4"]
2015-08-14 02:51:31,016 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/count4/_temporary
2015-08-14 02:51:31,085 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/count4
2015-08-14 02:51:31,105 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:31,106 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:31,120 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:31,120 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:31,121 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filter"]
2015-08-14 02:51:31,121 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:31,121 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:31,121 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:31,122 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/filter
2015-08-14 02:51:31,198 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1956200247/.staging/job_local1956200247_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:31,199 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1956200247/.staging/job_local1956200247_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:31,248 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1956200247_0016/job_local1956200247_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:31,249 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1956200247_0016/job_local1956200247_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:31,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1956200247_0016
2015-08-14 02:51:31,250 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:31,256 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:31,265 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:31,265 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:31,272 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:31,272 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filter"]
2015-08-14 02:51:31,295 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/filter/_temporary
2015-08-14 02:51:31,326 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/filter
2015-08-14 02:51:31,348 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:51:31,348 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 02:51:31,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting
2015-08-14 02:51:31,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] source: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:31,367 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] sink: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simple"]
2015-08-14 02:51:31,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] parallel execution is enabled: false
2015-08-14 02:51:31,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] starting jobs: 1
2015-08-14 02:51:31,368 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [test] allocating threads: 1
2015-08-14 02:51:31,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] starting step: (1/1) ...basicpipesplatform/simple
2015-08-14 02:51:31,445 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1604134803/.staging/job_local1604134803_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:31,445 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1604134803/.staging/job_local1604134803_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:31,493 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1604134803_0017/job_local1604134803_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval; Ignoring.
2015-08-14 02:51:31,494 WARN conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1604134803_0017/job_local1604134803_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts; Ignoring.
2015-08-14 02:51:31,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] submitted hadoop job: job_local1604134803_0017
2015-08-14 02:51:31,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [test] tracking url: http://localhost:8080/
2015-08-14 02:51:31,500 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt
2015-08-14 02:51:31,525 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 02:51:31,525 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 02:51:31,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[[0:1]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache.10.txt"]
2015-08-14 02:51:31,534 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:31,555 INFO hadoop.FlowReducer (FlowReducer.java:configure(78)) - cascading version: 2.7.1
2015-08-14 02:51:31,556 INFO hadoop.FlowReducer (FlowReducer.java:configure(79)) - child jvm opts: -Xmx200m
2015-08-14 02:51:31,563 INFO hadoop.FlowReducer (FlowReducer.java:configure(97)) - sourcing from: GroupBy(test)[by:[{1}:0]]
2015-08-14 02:51:31,564 INFO hadoop.FlowReducer (FlowReducer.java:configure(100)) - sinking to: Hfs["TextLine[[0]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simple"]
2015-08-14 02:51:31,594 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/basicpipesplatform/simple/_temporary
2015-08-14 02:51:31,626 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/basicpipesplatform/simple