Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

11.459s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.494s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.455s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 2.439s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.333s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.379s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.024s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.304s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.325s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.028s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.334s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.320s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.319s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.034s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.236s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.222s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.226s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.297s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.302s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.301s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.296s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.021s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.264s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.021s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.285s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.282s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.281s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.285s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.029s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.219s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.198s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.214s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.268s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.264s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.267s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.267s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.283s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.024s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.267s passed

Standard output

2015-08-14 07:59:22,165 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 07:59:22,229 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,229 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2015-08-14 07:59:22,313 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,331 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,341 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,350 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,357 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,364 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,370 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,371 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,376 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,381 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,386 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,387 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,387 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,389 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,390 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,390 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,395 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,396 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,401 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,409 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,416 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,424 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,431 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,432 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,439 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,447 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,447 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,448 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,448 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,448 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,452 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,453 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,456 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,457 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,460 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,464 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,467 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,471 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,474 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,477 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop2-mr1
2015-08-14 07:59:22,795 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 07:59:23,453 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 07:59:23,619 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 07:59:23,739 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:23,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 07:59:23,755 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: FC3C9B05FABB4EC3B71A16A1693B496A
2015-08-14 07:59:23,973 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 07:59:23,974 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:23,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:23,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 07:59:23,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:23,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:23,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:23,978 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-14 07:59:24,734 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity215719059/.staging/job_local215719059_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:24,740 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity215719059/.staging/job_local215719059_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:24,872 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local215719059_0001/job_local215719059_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:24,876 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local215719059_0001/job_local215719059_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:24,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local215719059_0001
2015-08-14 07:59:24,886 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:24,981 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:25,008 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:25,008 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:25,070 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:25,071 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 07:59:25,142 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-14 07:59:25,232 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-08-14 07:59:25,263 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:25,264 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 07:59:25,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:25,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:25,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 07:59:25,299 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:25,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:25,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:25,301 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-14 07:59:25,438 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity639994778/.staging/job_local639994778_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:25,443 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity639994778/.staging/job_local639994778_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:25,524 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local639994778_0002/job_local639994778_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:25,527 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local639994778_0002/job_local639994778_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:25,528 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local639994778_0002
2015-08-14 07:59:25,529 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:25,539 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:25,553 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:25,553 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:25,565 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:25,566 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 07:59:25,598 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-14 07:59:25,689 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-14 07:59:25,718 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:25,718 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 07:59:25,747 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:25,747 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:25,747 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 07:59:25,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:25,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:25,749 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:25,752 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-14 07:59:25,931 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity391692582/.staging/job_local391692582_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:25,934 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity391692582/.staging/job_local391692582_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,008 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local391692582_0003/job_local391692582_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:26,011 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local391692582_0003/job_local391692582_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,012 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local391692582_0003
2015-08-14 07:59:26,014 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:26,024 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:26,039 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:26,039 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:26,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,052 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 07:59:26,093 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-14 07:59:26,183 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-14 07:59:26,212 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:26,213 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 07:59:26,241 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:26,241 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,241 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 07:59:26,242 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:26,243 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:26,243 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:26,244 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-14 07:59:26,345 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1829046708/.staging/job_local1829046708_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:26,347 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1829046708/.staging/job_local1829046708_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,419 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1829046708_0004/job_local1829046708_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:26,421 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1829046708_0004/job_local1829046708_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1829046708_0004
2015-08-14 07:59:26,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:26,430 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:26,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:26,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:26,454 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 07:59:26,492 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-14 07:59:26,563 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-14 07:59:26,586 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:26,586 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 07:59:26,610 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:26,611 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,611 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 07:59:26,611 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:26,612 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:26,612 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:26,613 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-14 07:59:26,705 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity702960636/.staging/job_local702960636_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:26,706 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity702960636/.staging/job_local702960636_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,769 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local702960636_0005/job_local702960636_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:26,770 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local702960636_0005/job_local702960636_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:26,771 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local702960636_0005
2015-08-14 07:59:26,771 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:26,779 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:26,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:26,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:26,802 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,802 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 07:59:26,829 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-14 07:59:26,896 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-14 07:59:26,918 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:26,919 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 07:59:26,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:26,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:26,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 07:59:26,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:26,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:26,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:26,949 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-14 07:59:27,041 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity7882544/.staging/job_local7882544_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,042 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity7882544/.staging/job_local7882544_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,100 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local7882544_0006/job_local7882544_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,101 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local7882544_0006/job_local7882544_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local7882544_0006
2015-08-14 07:59:27,102 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:27,110 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:27,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:27,122 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:27,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,133 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 07:59:27,162 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-14 07:59:27,232 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-14 07:59:27,252 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:27,252 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 07:59:27,261 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-14 07:59:27,280 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:27,280 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 07:59:27,300 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:27,301 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,301 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 07:59:27,301 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:27,301 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:27,302 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:27,302 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-14 07:59:27,393 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity560613009/.staging/job_local560613009_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,394 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity560613009/.staging/job_local560613009_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,448 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local560613009_0007/job_local560613009_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,450 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local560613009_0007/job_local560613009_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local560613009_0007
2015-08-14 07:59:27,451 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:27,458 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:27,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:27,469 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:27,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,479 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 07:59:27,517 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-14 07:59:27,586 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-14 07:59:27,607 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:27,607 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 07:59:27,628 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:27,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 07:59:27,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:27,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:27,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:27,630 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-14 07:59:27,718 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity563284784/.staging/job_local563284784_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,719 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity563284784/.staging/job_local563284784_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,774 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local563284784_0008/job_local563284784_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:27,775 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local563284784_0008/job_local563284784_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:27,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local563284784_0008
2015-08-14 07:59:27,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:27,783 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:27,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:27,795 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:27,804 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 07:59:27,833 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-14 07:59:27,905 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-14 07:59:27,927 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:27,927 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 07:59:27,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:27,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:27,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 07:59:27,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:27,947 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:27,948 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:27,948 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 07:59:28,041 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1777461739/.staging/job_local1777461739_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,042 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1777461739/.staging/job_local1777461739_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,096 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1777461739_0009/job_local1777461739_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,097 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1777461739_0009/job_local1777461739_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,098 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1777461739_0009
2015-08-14 07:59:28,098 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:28,107 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:28,118 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:28,118 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:28,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,128 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 07:59:28,156 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-14 07:59:28,225 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 07:59:28,246 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,247 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 07:59:28,266 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:28,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 07:59:28,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:28,267 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:28,268 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:28,268 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 07:59:28,356 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity569414908/.staging/job_local569414908_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,357 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity569414908/.staging/job_local569414908_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,412 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local569414908_0010/job_local569414908_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,413 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local569414908_0010/job_local569414908_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local569414908_0010
2015-08-14 07:59:28,414 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:28,422 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:28,432 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:28,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:28,441 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,442 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 07:59:28,444 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,446 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,447 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,450 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local569414908_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,456 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local569414908_0010 state at FAILED
2015-08-14 07:59:28,457 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:28,458 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:28,459 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:28,459 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:28,460 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 07:59:28,460 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:28,461 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-14 07:59:28,461 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-08-14 07:59:28,481 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,482 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 07:59:28,495 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-14 07:59:28,516 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,516 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 07:59:28,534 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:28,534 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 07:59:28,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:28,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:28,535 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:28,536 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 07:59:28,624 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity776113556/.staging/job_local776113556_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,626 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity776113556/.staging/job_local776113556_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,681 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local776113556_0011/job_local776113556_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,683 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local776113556_0011/job_local776113556_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,684 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local776113556_0011
2015-08-14 07:59:28,685 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:28,692 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:28,703 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:28,703 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:28,711 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,711 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 07:59:28,712 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,713 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,714 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,716 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local776113556_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,719 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local776113556_0011 state at FAILED
2015-08-14 07:59:28,719 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:28,719 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:28,719 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:28,720 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:28,720 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 07:59:28,721 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:28,721 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-14 07:59:28,721 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-14 07:59:28,740 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,741 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 07:59:28,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:28,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,757 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 07:59:28,758 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:28,758 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:28,758 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:28,759 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 07:59:28,848 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1934657961/.staging/job_local1934657961_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,849 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1934657961/.staging/job_local1934657961_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,903 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1934657961_0012/job_local1934657961_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:28,906 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1934657961_0012/job_local1934657961_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:28,907 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1934657961_0012
2015-08-14 07:59:28,907 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:28,913 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:28,923 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:28,924 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:28,932 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:28,932 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 07:59:28,933 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,934 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,934 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,937 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1934657961_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:28,938 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local1934657961_0012 state at FAILED
2015-08-14 07:59:28,941 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:28,941 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:28,941 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:28,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:28,942 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 07:59:28,942 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] shutting down job executor
2015-08-14 07:59:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] shutdown complete
2015-08-14 07:59:28,943 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-14 07:59:28,944 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-14 07:59:28,962 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,963 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 07:59:28,968 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-14 07:59:28,987 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:28,988 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 07:59:29,003 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:29,003 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,004 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 07:59:29,004 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:29,005 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:29,005 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:29,006 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-14 07:59:29,095 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1165648980/.staging/job_local1165648980_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,096 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1165648980/.staging/job_local1165648980_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,150 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1165648980_0013/job_local1165648980_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,151 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1165648980_0013/job_local1165648980_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,152 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1165648980_0013
2015-08-14 07:59:29,153 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:29,160 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:29,169 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:29,170 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:29,177 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,177 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 07:59:29,210 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-14 07:59:29,273 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-14 07:59:29,294 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:29,294 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 07:59:29,300 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-14 07:59:29,321 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:29,322 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 07:59:29,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:29,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 07:59:29,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:29,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:29,340 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:29,340 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-14 07:59:29,426 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity871493592/.staging/job_local871493592_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,427 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity871493592/.staging/job_local871493592_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,478 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local871493592_0014/job_local871493592_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,480 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local871493592_0014/job_local871493592_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,481 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local871493592_0014
2015-08-14 07:59:29,481 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:29,487 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:29,497 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:29,498 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:29,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 07:59:29,537 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-14 07:59:29,601 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-08-14 07:59:29,622 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:29,622 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 07:59:29,638 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:29,638 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 07:59:29,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:29,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:29,640 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:29,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-14 07:59:29,721 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity169149484/.staging/job_local169149484_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,723 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity169149484/.staging/job_local169149484_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,773 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local169149484_0015/job_local169149484_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:29,775 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local169149484_0015/job_local169149484_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:29,775 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local169149484_0015
2015-08-14 07:59:29,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:29,782 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:29,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:29,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:29,801 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,801 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 07:59:29,835 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-14 07:59:29,900 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-14 07:59:29,920 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:29,921 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 07:59:29,935 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:29,935 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:29,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 07:59:29,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:29,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:29,936 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:29,938 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-14 07:59:30,020 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity479980340/.staging/job_local479980340_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,022 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity479980340/.staging/job_local479980340_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,076 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local479980340_0016/job_local479980340_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,078 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local479980340_0016/job_local479980340_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,079 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local479980340_0016
2015-08-14 07:59:30,080 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:30,088 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:30,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:30,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:30,105 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,106 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 07:59:30,135 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-14 07:59:30,197 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-14 07:59:30,216 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:30,217 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 07:59:30,231 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:30,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,232 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 07:59:30,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:30,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:30,234 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:30,235 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-14 07:59:30,314 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity754275305/.staging/job_local754275305_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,315 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity754275305/.staging/job_local754275305_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,379 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local754275305_0017/job_local754275305_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,380 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local754275305_0017/job_local754275305_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,381 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local754275305_0017
2015-08-14 07:59:30,381 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:30,388 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:30,398 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:30,398 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:30,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,405 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 07:59:30,436 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-14 07:59:30,498 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-08-14 07:59:30,516 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:30,516 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 07:59:30,529 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:30,530 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,530 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 07:59:30,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:30,531 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:30,532 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:30,533 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-14 07:59:30,617 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity812164114/.staging/job_local812164114_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,618 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity812164114/.staging/job_local812164114_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,669 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local812164114_0018/job_local812164114_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,670 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local812164114_0018/job_local812164114_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,671 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local812164114_0018
2015-08-14 07:59:30,672 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:30,677 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:30,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:30,687 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:30,694 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,694 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 07:59:30,716 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-14 07:59:30,780 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-14 07:59:30,801 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:30,801 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 07:59:30,807 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-14 07:59:30,826 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:30,827 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 07:59:30,841 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:30,841 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:30,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 07:59:30,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:30,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:30,842 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:30,843 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-14 07:59:30,932 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1481327242/.staging/job_local1481327242_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,934 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1481327242/.staging/job_local1481327242_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,983 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1481327242_0019/job_local1481327242_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:30,984 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1481327242_0019/job_local1481327242_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:30,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1481327242_0019
2015-08-14 07:59:30,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:30,991 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:31,000 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:31,001 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:31,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,007 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 07:59:31,030 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-14 07:59:31,093 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-14 07:59:31,110 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:31,111 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 07:59:31,123 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:31,123 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,124 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 07:59:31,124 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:31,124 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:31,124 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:31,125 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-14 07:59:31,211 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1997235882/.staging/job_local1997235882_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,212 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1997235882/.staging/job_local1997235882_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,264 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1997235882_0020/job_local1997235882_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,266 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1997235882_0020/job_local1997235882_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,266 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1997235882_0020
2015-08-14 07:59:31,266 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:31,273 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:31,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:31,282 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:31,290 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,290 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 07:59:31,311 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-14 07:59:31,374 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-14 07:59:31,393 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:31,393 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 07:59:31,406 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:31,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 07:59:31,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:31,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:31,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:31,410 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 07:59:31,490 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1383653875/.staging/job_local1383653875_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,491 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1383653875/.staging/job_local1383653875_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,546 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1383653875_0021/job_local1383653875_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,547 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1383653875_0021/job_local1383653875_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,548 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1383653875_0021
2015-08-14 07:59:31,549 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:31,558 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:31,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:31,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:31,576 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,577 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 07:59:31,578 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,579 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,580 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,582 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1383653875_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,590 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local1383653875_0021 state at FAILED
2015-08-14 07:59:31,590 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:31,591 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:31,591 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:31,592 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:31,592 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 07:59:31,593 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:31,593 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-14 07:59:31,594 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-08-14 07:59:31,616 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:31,616 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 07:59:31,623 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-14 07:59:31,645 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:31,645 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 07:59:31,661 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:31,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 07:59:31,662 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:31,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:31,663 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:31,664 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 07:59:31,744 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity161088583/.staging/job_local161088583_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,746 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity161088583/.staging/job_local161088583_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,795 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local161088583_0022/job_local161088583_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,797 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local161088583_0022/job_local161088583_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,797 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local161088583_0022
2015-08-14 07:59:31,797 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:31,803 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:31,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:31,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:31,818 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,819 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 07:59:31,820 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,820 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,821 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,823 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local161088583_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:31,831 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local161088583_0022 state at FAILED
2015-08-14 07:59:31,832 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:31,832 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:31,832 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:31,833 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:31,833 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 07:59:31,836 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:31,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-14 07:59:31,836 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-14 07:59:31,853 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:31,854 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 07:59:31,864 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:31,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:31,865 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 07:59:31,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:31,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:31,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:31,867 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 07:59:31,946 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity2131660117/.staging/job_local2131660117_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,947 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity2131660117/.staging/job_local2131660117_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,996 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2131660117_0023/job_local2131660117_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:31,997 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2131660117_0023/job_local2131660117_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:31,998 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local2131660117_0023
2015-08-14 07:59:31,998 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:32,003 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:32,014 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:32,015 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:32,021 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,021 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 07:59:32,022 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:32,023 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:32,024 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:32,026 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local2131660117_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
2015-08-14 07:59:32,030 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local2131660117_0023 state at FAILED
2015-08-14 07:59:32,030 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 07:59:32,031 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 07:59:32,031 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 07:59:32,032 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 07:59:32,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 07:59:32,033 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 07:59:32,034 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-14 07:59:32,034 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-08-14 07:59:32,051 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,052 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 07:59:32,062 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:32,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 07:59:32,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:32,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:32,063 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:32,064 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-14 07:59:32,142 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity338617827/.staging/job_local338617827_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,143 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity338617827/.staging/job_local338617827_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,191 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local338617827_0024/job_local338617827_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,192 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local338617827_0024/job_local338617827_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local338617827_0024
2015-08-14 07:59:32,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:32,200 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:32,209 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:32,209 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:32,215 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 07:59:32,238 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-14 07:59:32,299 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-08-14 07:59:32,316 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,316 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 07:59:32,320 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-14 07:59:32,337 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,337 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 07:59:32,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:32,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 07:59:32,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:32,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:32,349 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:32,351 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-14 07:59:32,435 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1586207980/.staging/job_local1586207980_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,436 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1586207980/.staging/job_local1586207980_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,487 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1586207980_0025/job_local1586207980_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,488 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1586207980_0025/job_local1586207980_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1586207980_0025
2015-08-14 07:59:32,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:32,496 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:32,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:32,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:32,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 07:59:32,545 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-14 07:59:32,606 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-14 07:59:32,622 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,623 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 07:59:32,627 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-08-14 07:59:32,643 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,644 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 07:59:32,654 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:32,654 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,654 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 07:59:32,655 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:32,655 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:32,655 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:32,656 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-14 07:59:32,734 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity94197551/.staging/job_local94197551_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,735 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity94197551/.staging/job_local94197551_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,786 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local94197551_0026/job_local94197551_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:32,787 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local94197551_0026/job_local94197551_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:32,788 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local94197551_0026
2015-08-14 07:59:32,788 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:32,793 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:32,802 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:32,803 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:32,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 07:59:32,833 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-14 07:59:32,894 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-14 07:59:32,912 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:32,912 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 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:32,923 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:32,924 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-14 07:59:33,002 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity526232800/.staging/job_local526232800_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,003 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity526232800/.staging/job_local526232800_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,050 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local526232800_0027/job_local526232800_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,051 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local526232800_0027/job_local526232800_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local526232800_0027
2015-08-14 07:59:33,052 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:33,057 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:33,066 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:33,067 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:33,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 07:59:33,097 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-14 07:59:33,159 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-14 07:59:33,176 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:33,176 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 07:59:33,186 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:33,187 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 07:59:33,188 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:33,189 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:33,190 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:33,191 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-14 07:59:33,271 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1065335476/.staging/job_local1065335476_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,272 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1065335476/.staging/job_local1065335476_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,319 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1065335476_0028/job_local1065335476_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,320 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1065335476_0028/job_local1065335476_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,320 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1065335476_0028
2015-08-14 07:59:33,321 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:33,326 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:33,336 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:33,336 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:33,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 07:59:33,366 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-14 07:59:33,427 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-14 07:59:33,445 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:33,445 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 07:59:33,457 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:33,457 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,457 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 07:59:33,457 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:33,457 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:33,458 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:33,458 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-14 07:59:33,540 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1475353507/.staging/job_local1475353507_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,541 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1475353507/.staging/job_local1475353507_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,592 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1475353507_0029/job_local1475353507_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,593 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1475353507_0029/job_local1475353507_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,594 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1475353507_0029
2015-08-14 07:59:33,594 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:33,600 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:33,609 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:33,609 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:33,615 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,616 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 07:59:33,649 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-14 07:59:33,711 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-14 07:59:33,728 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:33,729 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 07:59:33,739 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:33,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 07:59:33,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:33,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:33,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:33,741 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-14 07:59:33,818 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1658145283/.staging/job_local1658145283_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,820 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1658145283/.staging/job_local1658145283_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,870 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1658145283_0030/job_local1658145283_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:33,872 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1658145283_0030/job_local1658145283_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:33,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1658145283_0030
2015-08-14 07:59:33,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:33,878 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:33,887 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:33,888 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:33,894 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:33,894 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 07:59:33,918 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-14 07:59:33,978 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-14 07:59:33,996 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:33,997 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 07:59:34,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 07:59:34,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:34,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 07:59:34,009 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 07:59:34,009 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 07:59:34,009 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 07:59:34,010 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 07:59:34,088 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1366442399/.staging/job_local1366442399_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:34,090 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/staging/teamcity1366442399/.staging/job_local1366442399_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:34,137 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1366442399_0031/job_local1366442399_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 07:59:34,138 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1366442399_0031/job_local1366442399_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 07:59:34,139 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1366442399_0031
2015-08-14 07:59:34,139 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 07:59:34,145 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt
2015-08-14 07:59:34,154 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 07:59:34,154 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 07:59:34,160 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2015-08-14 07:59:34,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 07:59:34,184 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-14 07:59:34,246 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 07:59:34,263 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 07:59:34,264 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 07:59:34,269 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'